Dheeraj Panangat
10/09/2023, 2:58 AMenvironment.setStreamTimeCharacteristic(TimeCharacteristic.EventTime); //for time based events
DataStream<JsonNode> timestampedStream = eventStateStream.assignTimestampsAndWatermarks(
WatermarkStrategy.<JsonNode>forBoundedOutOfOrderness(Duration.ofSeconds(120)).withTimestampAssigner((event, timestamp) -> {
return eventTime; //calculated event time
})
);
AllWindowedStream<JsonNode, TimeWindow> miniEventWindowedStream = timestampedStream.windowAll(SlidingEventTimeWindows.of(Time.days(2), Time.minutes(2)));
miniEventWindowedStream.apply(//my processing logic).print()
The print() here does not print the event. The eventTime returned is within the window.
Appreciate any thoughts or inputs here.
Thanks