データストリーム - 過去の日付のためのTimeWindow

Question

私は過去のイベントの時間

01-12-2015 01:10:10 
01-12-2015 01:10:20 
01-12-2015 01:10:30 
01-12-2015 01:10:40 
.... (millions of records) 

とのデータセットを持っている私は、データにEventTimeを取得するためにTimeExtractorクラスを持つことができ、このtimeWindow(Time.seconds(30))

ためtimeWindowを適用したいです。しかし、私はどのようにgetCurrentWatermarkメソッドを実装するのですか？過去の日付と時刻を取得する必要があります

Answer 1

TimeStampAssignershereを参照してください。

それでは、私が推薦することは、このようなものです：

DataStream<MyEvent> stream = ... 

DataStream<MyEvent> withTimestampsAndWatermarks = 
stream.assignTimestampsAndWatermarks(new AscendingTimestampExtractor<MyEvent>() { 

    @Override 
    public long extractAscendingTimestamp(MyEvent element) { 
     return element.getCreationTime(); 
    } 
}); 

またTimestampCharacteristic適切に設定することを忘れないでください：

env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);