org.apache.paimon.flink.metrics

Class FlinkCounter

java.lang.Object

org.apache.paimon.flink.metrics.FlinkCounter

All Implemented Interfaces:

Counter, Metric

public class FlinkCounter
extends Object
implements Counter

Counter which wraps a Flink's Counter.

Constructor Summary

Constructors

Constructor and Description
FlinkCounter(org.apache.flink.metrics.Counter wrapped)

Method Summary

Modifier and Type	Method and 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.paimon.metrics.Counter

getMetricType

Constructor Detail

FlinkCounter

public FlinkCounter(org.apache.flink.metrics.Counter wrapped)

Method Detail

inc

public void inc()

Description copied from interface: Counter

Increment the current count by 1.

Specified by:

inc in interface Counter

inc

public void inc(long n)

Description copied from interface: Counter

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()

Description copied from interface: Counter

Decrement the current count by 1.

Specified by:

dec in interface Counter

dec

public void dec(long n)

Description copied from interface: Counter

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()

Description copied from interface: Counter

Returns the current count.

Specified by:

getCount in interface Counter

Returns:

current count