Package org.apache.iceberg.metrics

Interface CommitMetricsResult

@Immutable
public interface CommitMetricsResult

A serializable version of CommitMetrics that carries its results.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	ADDED_DATA_FILES
static final String	ADDED_DELETE_FILES
static final String	ADDED_EQ_DELETE_FILES
static final String	ADDED_EQ_DELETES
static final String	ADDED_FILE_SIZE_BYTES
static final String	ADDED_POS_DELETE_FILES
static final String	ADDED_POS_DELETES
static final String	ADDED_RECORDS
static final String	REMOVED_DATA_FILES
static final String	REMOVED_DELETE_FILES
static final String	REMOVED_EQ_DELETE_FILES
static final String	REMOVED_EQ_DELETES
static final String	REMOVED_FILE_SIZE_BYTES
static final String	REMOVED_POS_DELETE_FILES
static final String	REMOVED_POS_DELETES
static final String	REMOVED_RECORDS
static final String	TOTAL_DATA_FILES
static final String	TOTAL_DELETE_FILES
static final String	TOTAL_EQ_DELETES
static final String	TOTAL_FILE_SIZE_BYTES
static final String	TOTAL_POS_DELETES
static final String	TOTAL_RECORDS

Method Summary

Modifier and Type	Method	Description
CounterResult	addedDataFiles()
CounterResult	addedDeleteFiles()
CounterResult	addedEqualityDeleteFiles()
CounterResult	addedEqualityDeletes()
CounterResult	addedFilesSizeInBytes()
CounterResult	addedPositionalDeleteFiles()
CounterResult	addedPositionalDeletes()
CounterResult	addedRecords()
CounterResult	attempts()
static CounterResult	counterFrom(Map<String,String> snapshotSummary, String metricName)
static CounterResult	counterFrom(Map<String,String> snapshotSummary, String metricName, MetricsContext.Unit unit)
static CommitMetricsResult	from(CommitMetrics commitMetrics, Map<String,String> snapshotSummary)
CounterResult	removedDataFiles()
CounterResult	removedDeleteFiles()
CounterResult	removedEqualityDeleteFiles()
CounterResult	removedEqualityDeletes()
CounterResult	removedFilesSizeInBytes()
CounterResult	removedPositionalDeleteFiles()
CounterResult	removedPositionalDeletes()
CounterResult	removedRecords()
CounterResult	totalDataFiles()
CounterResult	totalDeleteFiles()
TimerResult	totalDuration()
CounterResult	totalEqualityDeletes()
CounterResult	totalFilesSizeInBytes()
CounterResult	totalPositionalDeletes()
CounterResult	totalRecords()

Field Details

ADDED_DATA_FILES

static final String ADDED_DATA_FILES

See Also:

• Constant Field Values

REMOVED_DATA_FILES

static final String REMOVED_DATA_FILES

See Also:

• Constant Field Values

TOTAL_DATA_FILES

static final String TOTAL_DATA_FILES

See Also:

• Constant Field Values

ADDED_DELETE_FILES

static final String ADDED_DELETE_FILES

See Also:

• Constant Field Values

ADDED_EQ_DELETE_FILES

static final String ADDED_EQ_DELETE_FILES

See Also:

• Constant Field Values

ADDED_POS_DELETE_FILES

static final String ADDED_POS_DELETE_FILES

See Also:

• Constant Field Values

REMOVED_POS_DELETE_FILES

static final String REMOVED_POS_DELETE_FILES

See Also:

• Constant Field Values

REMOVED_EQ_DELETE_FILES

static final String REMOVED_EQ_DELETE_FILES

See Also:

• Constant Field Values

REMOVED_DELETE_FILES

static final String REMOVED_DELETE_FILES

See Also:

• Constant Field Values

TOTAL_DELETE_FILES

static final String TOTAL_DELETE_FILES

See Also:

• Constant Field Values

ADDED_RECORDS

static final String ADDED_RECORDS

See Also:

• Constant Field Values

REMOVED_RECORDS

static final String REMOVED_RECORDS

See Also:

• Constant Field Values

TOTAL_RECORDS

static final String TOTAL_RECORDS

See Also:

• Constant Field Values

ADDED_FILE_SIZE_BYTES

static final String ADDED_FILE_SIZE_BYTES

See Also:

• Constant Field Values

REMOVED_FILE_SIZE_BYTES

static final String REMOVED_FILE_SIZE_BYTES

See Also:

• Constant Field Values

TOTAL_FILE_SIZE_BYTES

static final String TOTAL_FILE_SIZE_BYTES

See Also:

• Constant Field Values

ADDED_POS_DELETES

static final String ADDED_POS_DELETES

See Also:

• Constant Field Values

REMOVED_POS_DELETES

static final String REMOVED_POS_DELETES

See Also:

• Constant Field Values

TOTAL_POS_DELETES

static final String TOTAL_POS_DELETES

See Also:

• Constant Field Values

ADDED_EQ_DELETES

static final String ADDED_EQ_DELETES

See Also:

• Constant Field Values

REMOVED_EQ_DELETES

static final String REMOVED_EQ_DELETES

See Also:

• Constant Field Values

TOTAL_EQ_DELETES

static final String TOTAL_EQ_DELETES

See Also:

• Constant Field Values

Method Details

totalDuration

@Nullable
TimerResult totalDuration()

attempts

@Nullable
CounterResult attempts()

addedDataFiles

@Nullable
CounterResult addedDataFiles()

removedDataFiles

@Nullable
CounterResult removedDataFiles()

totalDataFiles

@Nullable
CounterResult totalDataFiles()

addedDeleteFiles

@Nullable
CounterResult addedDeleteFiles()

addedEqualityDeleteFiles

@Nullable
CounterResult addedEqualityDeleteFiles()

addedPositionalDeleteFiles

@Nullable
CounterResult addedPositionalDeleteFiles()

removedDeleteFiles

@Nullable
CounterResult removedDeleteFiles()

removedEqualityDeleteFiles

@Nullable
CounterResult removedEqualityDeleteFiles()

removedPositionalDeleteFiles

@Nullable
CounterResult removedPositionalDeleteFiles()

totalDeleteFiles

@Nullable
CounterResult totalDeleteFiles()

addedRecords

@Nullable
CounterResult addedRecords()

removedRecords

@Nullable
CounterResult removedRecords()

totalRecords

@Nullable
CounterResult totalRecords()

addedFilesSizeInBytes

@Nullable
CounterResult addedFilesSizeInBytes()

removedFilesSizeInBytes

@Nullable
CounterResult removedFilesSizeInBytes()

totalFilesSizeInBytes

@Nullable
CounterResult totalFilesSizeInBytes()

addedPositionalDeletes

@Nullable
CounterResult addedPositionalDeletes()

removedPositionalDeletes

@Nullable
CounterResult removedPositionalDeletes()

totalPositionalDeletes

@Nullable
CounterResult totalPositionalDeletes()

addedEqualityDeletes

@Nullable
CounterResult addedEqualityDeletes()

removedEqualityDeletes

@Nullable
CounterResult removedEqualityDeletes()

totalEqualityDeletes

@Nullable
CounterResult totalEqualityDeletes()

from

static CommitMetricsResult from(CommitMetrics commitMetrics,
 Map<String,String> snapshotSummary)

counterFrom

static CounterResult counterFrom(Map<String,String> snapshotSummary,
 String metricName)

counterFrom

static CounterResult counterFrom(Map<String,String> snapshotSummary,
 String metricName,
 MetricsContext.Unit unit)