org.apache.paimon.flink.sink

Class CommitterMetrics

java.lang.Object

org.apache.paimon.flink.sink.CommitterMetrics

public class CommitterMetrics
extends Object

Flink metrics for Committer.

Constructor Summary

Constructors

Constructor and Description
CommitterMetrics(org.apache.flink.metrics.groups.OperatorIOMetricGroup metricGroup)

Method Summary

Modifier and Type	Method and Description
org.apache.flink.metrics.Counter	getNumBytesOutCounter()
org.apache.flink.metrics.Counter	getNumRecordsOutCounter()
void	increaseNumBytesOut(long numBytesOut)
void	increaseNumRecordsOut(long numRecordsOut)

Methods inherited from class java.lang.Object

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

Constructor Detail

CommitterMetrics

public CommitterMetrics(org.apache.flink.metrics.groups.OperatorIOMetricGroup metricGroup)

Method Detail

increaseNumBytesOut

public void increaseNumBytesOut(long numBytesOut)

increaseNumRecordsOut

public void increaseNumRecordsOut(long numRecordsOut)

getNumBytesOutCounter

@VisibleForTesting
public org.apache.flink.metrics.Counter getNumBytesOutCounter()

getNumRecordsOutCounter

@VisibleForTesting
public org.apache.flink.metrics.Counter getNumRecordsOutCounter()