Что такое замена EventTimeSourceFunction (Flink 0.10.x) в Flink 1.x?

Question

Я пытаюсь перенести пример SlidingArrivalCount.scala, основанный на Flink 0.10.1 на Flink 1.1.1.

Источник данных источника данных TaxiRideSource, используемый в примере, реализует интерфейс org.apache.flink.streaming.api.functions.source.EventTimeSourceFunction, который больше не предоставляется Flink 1.x.

Как порт TaxiRideSource на Flink 1.x?

Answer 1

Начиная с Flink 1.0.0, все SourceFunction могут работать в режиме времени события, то есть у них есть интерфейсы для этого.

Функции источника, которые реализуют EventTimeSourceFunction, могут быть модернизированы до Flink 1.x, заменив EventTimeSourceFunction на SourceFunction.