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

Reply via email to