我正在尝试将基于flink 0.10.1的slidingarrivalcount.scala示例迁移到flink 1.1.1。
这个 TaxiRideSource 示例中使用的数据流源实现 org.apache.flink.streaming.api.functions.source.EventTimeSourceFunction 接口，它不再由flink1.x提供。
你怎么能让港口 TaxiRideSource 去flink 1.x？
我正在尝试将基于flink 0.10.1的slidingarrivalcount.scala示例迁移到flink 1.1.1。
这个 TaxiRideSource 示例中使用的数据流源实现 org.apache.flink.streaming.api.functions.source.EventTimeSourceFunction 接口，它不再由flink1.x提供。
你怎么能让港口 TaxiRideSource 去flink 1.x？
1条答案
按热度按时间gorkyyrv1#
从flink 1.0.0开始
SourceFunction可以在事件时间模式下运行，也就是说，它们有相应的接口。实现的源函数
EventTimeSourceFunction可以升级到flink 1.x，方法是EventTimeSourceFunction由SourceFunction.