apache flink:我们能从窗口化的join apply函数中获得windowstarttime和windowendtime吗?

hl0ma9xz  于 2021-07-15  发布在  Flink
关注(0)|答案(0)|浏览(213)

我正在ApacheFlink中实现两个流的简单连接。我需要windowstarttime和windowendtime在窗口连接应用函数。有什么办法可以得到它们吗?我尝试了“getruntimecontext()”,但没有成功。    

streamA.join(streamB)
            .where(new KeySelector<String, String>() {
                @Override
                public String getKey(String str) throws Exception {
                    return str;
                }
            }).equalTo(new KeySelector<String, String>() {
                @Override
                public String getKey(String str) throws Exception {
                    return str;
                }
            }).window(SlidingEventTimeWindows.of(Time.seconds(windowSize), Time.seconds(windowSlideStep)))
            .apply(new JoinFunction<String, String, String>(){
    @Override
    public String join(String x, String y) throws Exception {

                    Long windowStartTime = ???
                    Long windowEndTime = ???
           }});

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题