如何解决Apache Flink:我们可以从窗口连接应用函数中获取 windowStartTime 和 windowEndTime 吗?
我正在 Apache Flink 中实现两个流的简单连接。我在窗口连接应用函数中需要 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 = ???
}});
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。