Package org.apache.flink.metrics

Class ThreadSafeSimpleCounter

java.lang.Object

org.apache.flink.metrics.ThreadSafeSimpleCounter

All Implemented Interfaces:

Counter, Metric

@Internal
public class ThreadSafeSimpleCounter
extends Object
implements Counter

A simple low-overhead Counter that is thread-safe.

Constructor Summary

Constructors

Constructor	Description
ThreadSafeSimpleCounter()

Method Summary

Modifier and Type	Method	Description
void	dec()	Decrement the current count by 1.
void	dec(long n)	Decrement the current count by the given value.
long	getCount()	Returns the current count.
void	inc()	Increment the current count by 1.
void	inc(long n)	Increment the current count by the given value.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.metrics.Counter

getMetricType

Constructor Detail

ThreadSafeSimpleCounter

public ThreadSafeSimpleCounter()

Method Detail

inc

public void inc()

Increment the current count by 1.

Specified by:

inc in interface Counter

inc

public void inc(long n)

Increment the current count by the given value.

Specified by:

inc in interface Counter

Parameters:

n - value to increment the current count by

dec

public void dec()

Decrement the current count by 1.

Specified by:

dec in interface Counter

dec

public void dec(long n)

Decrement the current count by the given value.

Specified by:

dec in interface Counter

Parameters:

n - value to decrement the current count by

getCount

public long getCount()

Returns the current count.

Specified by:

getCount in interface Counter

Returns:

current count