Class IcebergSourceReaderMetrics
- java.lang.Object
-
- org.apache.iceberg.flink.source.reader.IcebergSourceReaderMetrics
-
public class IcebergSourceReaderMetrics extends java.lang.Object
-
-
Constructor Summary
Constructors Constructor Description IcebergSourceReaderMetrics(org.apache.flink.metrics.MetricGroup metrics, java.lang.String fullTableName)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
incrementAssignedBytes(long count)
void
incrementAssignedSplits(long count)
void
incrementFinishedBytes(long count)
void
incrementFinishedSplits(long count)
void
incrementSplitReaderFetchCalls(long count)
-
-
-
Method Detail
-
incrementAssignedSplits
public void incrementAssignedSplits(long count)
-
incrementAssignedBytes
public void incrementAssignedBytes(long count)
-
incrementFinishedSplits
public void incrementFinishedSplits(long count)
-
incrementFinishedBytes
public void incrementFinishedBytes(long count)
-
incrementSplitReaderFetchCalls
public void incrementSplitReaderFetchCalls(long count)
-
-