Hi All, I want to know if flink allows to define sliding window size and slide time on the fly. For example I want to configure sliding window of size 2 min and slide 1 min for tenant A but size 10 min and slide min for tenant B in a keyed stream and so on for other tenants. My code is below.
final DataStream<WindowStats> eventStream = inputStream .keyBy(TENANT, CATEGORY) .window(SlidingProcessingTimeWindows.of(Time.minutes(2,Time.minute(1))) .fold(new WindowStats(), newProductAggregationMapper(), newProductAggregationWindowFunction()); Can I do that for unlimited number of tenants in flink ? Cheers, Dr. Ahmad Hassan
