public class IcebergSourceReaderMetrics
extends java.lang.Object
Constructor and Description |
---|
IcebergSourceReaderMetrics(org.apache.flink.metrics.MetricGroup metrics,
java.lang.String fullTableName) |
Modifier and Type | Method and Description |
---|---|
void |
incrementAssignedBytes(long count) |
void |
incrementAssignedSplits(long count) |
void |
incrementFinishedBytes(long count) |
void |
incrementFinishedSplits(long count) |
void |
incrementSplitReaderFetchCalls(long count) |
public IcebergSourceReaderMetrics(org.apache.flink.metrics.MetricGroup metrics, java.lang.String fullTableName)
public void incrementAssignedSplits(long count)
public void incrementAssignedBytes(long count)
public void incrementFinishedSplits(long count)
public void incrementFinishedBytes(long count)
public void incrementSplitReaderFetchCalls(long count)