public class CommitStats extends Object
Constructor and Description |
---|
CommitStats(List<ManifestEntry> appendTableFiles,
List<ManifestEntry> appendChangelogFiles,
List<ManifestEntry> compactTableFiles,
List<ManifestEntry> compactChangelogFiles,
long commitDuration,
int generatedSnapshots,
int attempts) |
public CommitStats(List<ManifestEntry> appendTableFiles, List<ManifestEntry> appendChangelogFiles, List<ManifestEntry> compactTableFiles, List<ManifestEntry> compactChangelogFiles, long commitDuration, int generatedSnapshots, int attempts)
@VisibleForTesting protected static long numChangedPartitions(List<ManifestEntry>... changes)
@VisibleForTesting protected static long numChangedBuckets(List<ManifestEntry>... changes)
@VisibleForTesting protected static List<BinaryRow> changedPartitions(List<ManifestEntry>... changes)
@VisibleForTesting protected static Map<BinaryRow,Set<Integer>> changedPartBuckets(List<ManifestEntry>... changes)
@VisibleForTesting protected long getTableFilesAdded()
@VisibleForTesting protected long getTableFilesDeleted()
@VisibleForTesting protected long getTableFilesAppended()
@VisibleForTesting protected long getTableFilesCompacted()
@VisibleForTesting protected long getChangelogFilesAppended()
@VisibleForTesting protected long getChangelogFilesCompacted()
@VisibleForTesting protected long getGeneratedSnapshots()
@VisibleForTesting protected long getDeltaRecordsAppended()
@VisibleForTesting protected long getChangelogRecordsAppended()
@VisibleForTesting protected long getDeltaRecordsCompacted()
@VisibleForTesting protected long getChangelogRecordsCompacted()
@VisibleForTesting protected long getNumPartitionsWritten()
@VisibleForTesting protected long getNumBucketsWritten()
@VisibleForTesting protected long getDuration()
@VisibleForTesting protected int getAttempts()
public long getCompactionInputFileSize()
public long getCompactionOutputFileSize()
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.