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_DVS
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	CREATED_MANIFESTS_COUNT
static final String	KEPT_MANIFESTS_COUNT
static final String	PROCESSED_MANIFEST_ENTRY_COUNT
static final String	REMOVED_DATA_FILES
static final String	REMOVED_DELETE_FILES
static final String	REMOVED_DVS
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	REPLACED_MANIFESTS_COUNT
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()
default CounterResult	addedDVs()
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)
default CounterResult	manifestEntriesProcessed()
default CounterResult	manifestsCreated()
default CounterResult	manifestsKept()
default CounterResult	manifestsReplaced()
CounterResult	removedDataFiles()
CounterResult	removedDeleteFiles()
default CounterResult	removedDVs()
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

ADDED_DVS

static final String ADDED_DVS

See Also:

• Constant Field Values

REMOVED_POS_DELETE_FILES

static final String REMOVED_POS_DELETE_FILES

See Also:

• Constant Field Values

REMOVED_DVS

static final String REMOVED_DVS

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

KEPT_MANIFESTS_COUNT

static final String KEPT_MANIFESTS_COUNT

See Also:

• Constant Field Values

CREATED_MANIFESTS_COUNT

static final String CREATED_MANIFESTS_COUNT

See Also:

• Constant Field Values

REPLACED_MANIFESTS_COUNT

static final String REPLACED_MANIFESTS_COUNT

See Also:

• Constant Field Values

PROCESSED_MANIFEST_ENTRY_COUNT

static final String PROCESSED_MANIFEST_ENTRY_COUNT

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()

addedDVs

@Nullable
@Default
default CounterResult addedDVs()

removedDeleteFiles

@Nullable
CounterResult removedDeleteFiles()

removedEqualityDeleteFiles

@Nullable
CounterResult removedEqualityDeleteFiles()

removedPositionalDeleteFiles

@Nullable
CounterResult removedPositionalDeleteFiles()

removedDVs

@Nullable
@Default
default CounterResult removedDVs()

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()

manifestsCreated

@Nullable
@Default
default CounterResult manifestsCreated()

manifestsReplaced

@Nullable
@Default
default CounterResult manifestsReplaced()

manifestsKept

@Nullable
@Default
default CounterResult manifestsKept()

manifestEntriesProcessed

@Nullable
@Default
default CounterResult manifestEntriesProcessed()

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)