Hi to all, from what I understood a ProcessWindowFunction can only be used in the Streaming API. Is there any plan to port them also in the Table API (in the near future)? I'd like to do with Table API the equivalent of:
final DataStream<MyPojoEvent> events = env.addSource(src); events.filter(e -> e.getCode() != null) .keyBy(event -> Integer.valueOf(event.getCode())) .window(TumblingProcessingTimeWindows.of(Time.minutes(1))) .process(new ProcessWindowFunction<MyPojoEvent, MyPojoEvent, Integer, TimeWindow>() {.....}); Best, Flavio