Re: Custom Metrics in Windowed AggregateFunction

2018-12-19 Thread Chirag Dewan
That was my first alternative actually :) That works well for per window metrics. And though it fits perfectly for smaller windows, it might not be frequent enough for larger window sizes.  Thanks, Chirag  On Wednesday, 19 December, 2018, 4:15:41 PM IST, Dawid Wysakowicz wrote: Hi Chir

Re: Custom Metrics in Windowed AggregateFunction

2018-12-19 Thread Dawid Wysakowicz
Hi Chirag, I am afraid you are right you cannot access metrics from within AggregateFunction in WindowedStream. You can though use rich variant of WindowFunction, which is invoked for every window with the results of AggregateFunction. Would that be enough for your use case to use .aggregate(aggre

Custom Metrics in Windowed AggregateFunction

2018-12-18 Thread Chirag Dewan
Hi, I am writing a Flink job for aggregating events in a window.  I am trying to use the AggregateFunction implementation for this.  Now, since WindowedStream does not allow a RichAggregateFunction for aggregation, I cant use the RuntimeContext to get the Metric group.  I dont even see any other w