Package org.apache.iceberg.flink.sink

Class IcebergStreamWriterMetrics

java.lang.Object

org.apache.iceberg.flink.sink.IcebergStreamWriterMetrics

@Internal
public class IcebergStreamWriterMetrics
extends Object

Constructor Summary

Constructors

Constructor	Description
IcebergStreamWriterMetrics(org.apache.flink.metrics.MetricGroup metrics, String fullTableName)

Method Summary

Modifier and Type	Method	Description
void	flushDuration(long flushDurationMs)
org.apache.flink.metrics.Counter	getFlushedDataFiles()
org.apache.flink.metrics.Counter	getFlushedDeleteFiles()
void	updateFlushResult(WriteResult result)

Methods inherited from class java.lang.Object

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

Constructor Details

IcebergStreamWriterMetrics

public IcebergStreamWriterMetrics(org.apache.flink.metrics.MetricGroup metrics,
 String fullTableName)

Method Details

updateFlushResult

public void updateFlushResult(WriteResult result)

flushDuration

public void flushDuration(long flushDurationMs)

getFlushedDataFiles

public org.apache.flink.metrics.Counter getFlushedDataFiles()

getFlushedDeleteFiles

public org.apache.flink.metrics.Counter getFlushedDeleteFiles()