Flink 1.xのEventTimeSourceFunction（Flink 0.10.x）の置き換えは何ですか？

Question

Flink 0.10.1に基づくFlicker 1.1.1へのSlidingArrivalCount.scalaの例を移行しようとしています。

この例で使用されているTaxiRideSourceデータストリームソースは、org.apache.flink.streaming.api.functions.source.EventTimeSourceFunctionインターフェイスを実装していますが、これはもはやFlink 1.xでは提供されません。

TaxiRideSourceをFlink 1.xに移植するにはどうすればよいですか？

Answer 1

Flink 1.0.0以来、すべてSourceFunctionはEvent timeモードで動作することができます。つまり、インターフェイスはそのように動作します。

EventTimeSourceFunctionを実装するソース関数は、EventTimeSourceFunctionをSourceFunctionに置き換えることで、Flink 1.xにアップグレードできます。