微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

Apache Flink:我们可以从窗口连接应用函数中获取 windowStartTime 和 windowEndTime 吗?

如何解决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 举报,一经查实,本站将立刻删除。