startTime is set at start of function:
long startTime = System.currentTimeMillis();
On Tue, Jan 12, 2021 at 3:59 PM Manish G <manish.c.ghildi...@gmail.com>
wrote:
> 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?
>> >
>> >
>>
>>
