org.apache.flink.statefun.flink.core.metrics

Class NonNegativeCounter

java.lang.Object

org.apache.flink.statefun.flink.core.metrics.NonNegativeCounter

All Implemented Interfaces:

org.apache.flink.metrics.Counter, org.apache.flink.metrics.Metric

public class NonNegativeCounter
extends java.lang.Object
implements org.apache.flink.metrics.Counter

A simple counter that can never go below zero.

This class is used in a non-thread safe manner, so it is important all modifications are checked before updating the count. Otherwise, negative values might be reported.

Constructor Summary

Constructors

Constructor and Description
NonNegativeCounter()

Method Summary

Modifier and Type	Method and Description
void	dec()
void	dec(long value)
long	getCount()
void	inc()
void	inc(long value)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

NonNegativeCounter

public NonNegativeCounter()

Method Detail

inc

public void inc()

Specified by:

inc in interface org.apache.flink.metrics.Counter

inc

public void inc(long value)

Specified by:

inc in interface org.apache.flink.metrics.Counter

dec

public void dec()

Specified by:

dec in interface org.apache.flink.metrics.Counter

dec

public void dec(long value)

Specified by:

dec in interface org.apache.flink.metrics.Counter

getCount

public long getCount()

Specified by:

getCount in interface org.apache.flink.metrics.Counter