My code is: public class SimpleGauge<T> implements Gauge<T> {
private T mValue; @Override public T getValue() { return mValue; } public void setValue(T value){ mValue = value; } } And in flatmap function: float endTime = (System.currentTimeMillis() - startTime) / 1000F; this.simplegauge.setValue(endTime); So does it mean when flink calls my getValue function to accumulate the value, and not to take it as snapshot? On Tue, Jan 12, 2021 at 3:53 PM Chesnay Schepler <ches...@apache.org> wrote: > Sure, that might work. Be aware though that time measurements are, > compared to the logic within a function, usually rather expensive and > may impact performance. > > On 1/12/2021 10:57 AM, Manish G wrote: > > Hi All, > > > > I have implemented a flatmap function and I want to collect metrics > > for average time for this function which I plan to monitor via > prometheus. > > > > What would be good approach for it? I have added a gauge to the > > method(extending Gauge interface from flink API). Would it work for my > > needs? > > > > > >