Flink 1.x 中 EventTimeSourceFunction (Flink 0.10.x) 的替换是什么？
What is replacement of EventTimeSourceFunction (Flink 0.10.x) in Flink 1.x?
我正在尝试将基于 Flink 0.10.1 的 SlidingArrivalCount.scala 示例迁移到 Flink 1.1.1。
示例中使用的TaxiRideSource数据流源实现了org.apache.flink.streaming.api.functions.source.EventTimeSourceFunction接口，Flink不再提供1.x。
端口TaxiRideSource如何连接到Flink1.x？
从 Flink 1.0.0 开始，所有 SourceFunction 都可以在 Event time 模式下运行，也就是说，它们具有相应的接口。
实现 EventTimeSourceFunction 的源函数可以升级到 Flink 1.x，方法是将 EventTimeSourceFunction 替换为 SourceFunction。
我正在尝试将基于 Flink 0.10.1 的 SlidingArrivalCount.scala 示例迁移到 Flink 1.1.1。
示例中使用的TaxiRideSource数据流源实现了org.apache.flink.streaming.api.functions.source.EventTimeSourceFunction接口，Flink不再提供1.x。
端口TaxiRideSource如何连接到Flink1.x？
从 Flink 1.0.0 开始，所有 SourceFunction 都可以在 Event time 模式下运行，也就是说，它们具有相应的接口。
实现 EventTimeSourceFunction 的源函数可以升级到 Flink 1.x，方法是将 EventTimeSourceFunction 替换为 SourceFunction。