Re: Metrics for average time taken by flatMap function

[Manish G]

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?
> >
> >
>
>