Работа с окнами происходит в бесконечном цикле или что-то в этом роде, я печатаю поток данных после обработки, но похоже, что он вообще не достигает этой точки.
Ниже приведен мой псевдокод.
Datastream env = StreamExecutionEnvironment.getExecutionEnvironment()
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime)
Datastream stream = env.addSource() .map(mapping to java object)
.filter(filter for specific type of events)
.assignTimestampsAndWatermarks(
new BoundedOutOfOrdernessTimestampExtractor(Time.seconds(2)){})
Datastream processedStream = stream .keyBy(...)
.window(TumblingEventTimeWindows.of(Time.seconds(10))) .reduce()
processedStream.print()
Я добавил журнал для печати в функции уменьшения.Журналы печатаются из функции уменьшения.но поток не печатается.
И исходные данные потоковой передачи являются данными истории, т.е.данные за 2 месяца.в случае потоковой передачи данных истории необходимо установить что-то еще?
Любые входные данные будут очень полезны ..