Class IcebergSourceReaderMetrics


  • public class IcebergSourceReaderMetrics
    extends java.lang.Object
    • 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)