Uses of Interface
org.apache.flink.metrics.Counter

Packages that use Counter

Package	Description
org.apache.flink.metrics
org.apache.flink.metrics.groups
org.apache.flink.metrics.reporter

Uses of Counter in org.apache.flink.metrics

Classes in org.apache.flink.metrics that implement Counter

Modifier and Type	Class	Description
class	SimpleCounter	A simple low-overhead Counter that is not thread-safe.
class	ThreadSafeSimpleCounter	A simple low-overhead Counter that is thread-safe.

Methods in org.apache.flink.metrics with type parameters of type Counter

Modifier and Type	Method	Description
default <C extends Counter> C	MetricGroup.counter(int name, C counter)	Registers a Counter with Flink.
<C extends Counter> C	MetricGroup.counter(String name, C counter)	Registers a Counter with Flink.

Methods in org.apache.flink.metrics that return Counter

Modifier and Type	Method	Description
default Counter	MetricGroup.counter(int name)	Creates and registers a new Counter with Flink.
Counter	MetricGroup.counter(String name)	Creates and registers a new Counter with Flink.

Constructors in org.apache.flink.metrics with parameters of type Counter

Constructor	Description
MeterView(Counter counter)
MeterView(Counter counter, int timeSpanInSeconds)

Uses of Counter in org.apache.flink.metrics.groups

Methods in org.apache.flink.metrics.groups with type parameters of type Counter

Modifier and Type	Method	Description
<C extends Counter> C	UnregisteredMetricsGroup.counter(String name, C counter)

Methods in org.apache.flink.metrics.groups that return Counter

Modifier and Type	Method	Description
Counter	UnregisteredMetricsGroup.counter(String name)
Counter	OperatorIOMetricGroup.getNumBytesInCounter()	The total number of input bytes since the task started.
Counter	OperatorIOMetricGroup.getNumBytesOutCounter()	The total number of output bytes since the task started.
Counter	SinkWriterMetricGroup.getNumBytesSendCounter()	The total number of output send bytes since the task started.
Counter	SinkCommitterMetricGroup.getNumCommittablesAlreadyCommittedCounter()	The total number of already committed committables.
Counter	SinkCommitterMetricGroup.getNumCommittablesFailureCounter()	The total number of committable failures.
Counter	SinkCommitterMetricGroup.getNumCommittablesRetryCounter()	The total number of committable retry.
Counter	SinkCommitterMetricGroup.getNumCommittablesSuccessCounter()	The total number of successful committables.
Counter	SinkCommitterMetricGroup.getNumCommittablesTotalCounter()	The total number of committables arrived.
Counter	OperatorIOMetricGroup.getNumRecordsInCounter()	The total number of input records since the operator started.
Counter	SourceReaderMetricGroup.getNumRecordsInErrorsCounter()	The total number of record that failed to consume, process, or emit.
Counter	OperatorIOMetricGroup.getNumRecordsOutCounter()	The total number of output records since the operator started.
Counter	SinkWriterMetricGroup.getNumRecordsOutErrorsCounter()	The total number of records failed to send.
Counter	SinkWriterMetricGroup.getNumRecordsSendCounter()	The total number of records have been sent to the downstream system.
Counter	SinkWriterMetricGroup.getNumRecordsSendErrorsCounter()	The total number of records failed to send.

Methods in org.apache.flink.metrics.groups with parameters of type Counter

Modifier and Type	Method	Description
void	CacheMetricGroup.hitCounter(Counter hitCounter)	The number of cache hits.
void	CacheMetricGroup.loadCounter(Counter loadCounter)	The number of times to load data into cache from external system.
void	CacheMetricGroup.missCounter(Counter missCounter)	The number of cache misses.
void	CacheMetricGroup.numLoadFailuresCounter(Counter numLoadFailuresCounter)	The number of load failures.

Uses of Counter in org.apache.flink.metrics.reporter

Fields in org.apache.flink.metrics.reporter with type parameters of type Counter

Modifier and Type	Field	Description
protected Map<Counter,String>	AbstractReporter.counters