Thanks Fabian for the advice! Best Regards,
Dr. Ahmad Hassan On 23 June 2017 at 09:05, Fabian Hueske <fhue...@gmail.com> wrote: > Hi Ahmad, > > that is not possible, at least not with Flink's built-in windows. > You can probably implement something like that on top of the DataStream > API but I think it would quite a bit of effort. > > IMO, the better approach would be to start a separate Flink job per > tenant. This would also improve the isolation and failure behavior. > > Best, Fabian > > 2017-06-22 19:43 GMT+02:00 Ahmad Hassan <ahmad.has...@gmail.com>: > >> 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 > > >
