Package org.apache.iceberg.flink.source.reader

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

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)

Methods inherited from class java.lang.Object

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

Constructor Detail

IcebergSourceReaderMetrics

public IcebergSourceReaderMetrics(org.apache.flink.metrics.MetricGroup metrics,
                                  java.lang.String fullTableName)

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)