Hi, Need to calculate a 4 hour time window for count, sum with current calculated results being output every 5 mins. How do i do that ? Currently, I calculate results for 5 sec and 5 min time windows fine on the KeyedStream.
Time timeWindow = getTimeWindowFromInterval(interval);//eg: timeWindow = > Time.seconds(timeIntervalL); > KeyedStream<Map<String, Object>, ...> monitoringTupleKeyedStream = > kinesisStream.keyBy(...); > final WindowedStream<Map<String, Object>, ...., TimeWindow> windowStream = > monitoringTupleKeyedStream > .timeWindow(timeWindow); > DataStream<....> enrichedMGStream = windowStream.aggregate( > new MGroupingWindowAggregateClass(...), > new MGroupingAggregateClass(....)) > .map(new Monitoring...(...)); > enrichedMGStream.addSink(..); > TIA, Vijay
