org.apache.paimon.operation.metrics

Class CommitStats

java.lang.Object

org.apache.paimon.operation.metrics.CommitStats

public class CommitStats
extends Object

Statistics for a commit.

Constructor Summary

Constructors

Constructor and Description
CommitStats(List<ManifestEntry> appendTableFiles, List<ManifestEntry> appendChangelogFiles, List<ManifestEntry> compactTableFiles, List<ManifestEntry> compactChangelogFiles, long commitDuration, int generatedSnapshots, int attempts)

Method Summary

Modifier and Type	Method and Description
protected static Map<BinaryRow,Set<Integer>>	changedPartBuckets(List<ManifestEntry>... changes)
protected static List<BinaryRow>	changedPartitions(List<ManifestEntry>... changes)
protected int	getAttempts()
protected long	getChangelogFilesAppended()
protected long	getChangelogFilesCompacted()
protected long	getChangelogRecordsAppended()
protected long	getChangelogRecordsCompacted()
long	getCompactionInputFileSize()
long	getCompactionOutputFileSize()
protected long	getDeltaRecordsAppended()
protected long	getDeltaRecordsCompacted()
protected long	getDuration()
protected long	getGeneratedSnapshots()
protected long	getNumBucketsWritten()
protected long	getNumPartitionsWritten()
protected long	getTableFilesAdded()
protected long	getTableFilesAppended()
protected long	getTableFilesCompacted()
protected long	getTableFilesDeleted()
protected static long	numChangedBuckets(List<ManifestEntry>... changes)
protected static long	numChangedPartitions(List<ManifestEntry>... changes)

Methods inherited from class java.lang.Object

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

Constructor Detail

CommitStats

public CommitStats(List<ManifestEntry> appendTableFiles,
                   List<ManifestEntry> appendChangelogFiles,
                   List<ManifestEntry> compactTableFiles,
                   List<ManifestEntry> compactChangelogFiles,
                   long commitDuration,
                   int generatedSnapshots,
                   int attempts)

Method Detail

numChangedPartitions

@VisibleForTesting
protected static long numChangedPartitions(List<ManifestEntry>... changes)

numChangedBuckets

@VisibleForTesting
protected static long numChangedBuckets(List<ManifestEntry>... changes)

changedPartitions

@VisibleForTesting
protected static List<BinaryRow> changedPartitions(List<ManifestEntry>... changes)

changedPartBuckets

@VisibleForTesting
protected static Map<BinaryRow,Set<Integer>> changedPartBuckets(List<ManifestEntry>... changes)

getTableFilesAdded

@VisibleForTesting
protected long getTableFilesAdded()

getTableFilesDeleted

@VisibleForTesting
protected long getTableFilesDeleted()

getTableFilesAppended

@VisibleForTesting
protected long getTableFilesAppended()

getTableFilesCompacted

@VisibleForTesting
protected long getTableFilesCompacted()

getChangelogFilesAppended

@VisibleForTesting
protected long getChangelogFilesAppended()

getChangelogFilesCompacted

@VisibleForTesting
protected long getChangelogFilesCompacted()

getGeneratedSnapshots

@VisibleForTesting
protected long getGeneratedSnapshots()

getDeltaRecordsAppended

@VisibleForTesting
protected long getDeltaRecordsAppended()

getChangelogRecordsAppended

@VisibleForTesting
protected long getChangelogRecordsAppended()

getDeltaRecordsCompacted

@VisibleForTesting
protected long getDeltaRecordsCompacted()

getChangelogRecordsCompacted

@VisibleForTesting
protected long getChangelogRecordsCompacted()

getNumPartitionsWritten

@VisibleForTesting
protected long getNumPartitionsWritten()

getNumBucketsWritten

@VisibleForTesting
protected long getNumBucketsWritten()

getDuration

@VisibleForTesting
protected long getDuration()

getAttempts

@VisibleForTesting
protected int getAttempts()

getCompactionInputFileSize

public long getCompactionInputFileSize()

getCompactionOutputFileSize

public long getCompactionOutputFileSize()