Package org.apache.iceberg

Class PartitionStats

java.lang.Object

org.apache.iceberg.PartitionStats

All Implemented Interfaces:

StructLike

public class PartitionStats
extends java.lang.Object
implements StructLike

Constructor Summary

Constructors

Constructor	Description
PartitionStats(StructLike partition, int specId)

Method Summary

Modifier and Type	Method	Description
void	appendStats(PartitionStats entry)	Appends statistics from given entry to current entry.
int	dataFileCount()
long	dataRecordCount()
void	deletedEntry(Snapshot snapshot)	Updates the modified time and snapshot ID for the deleted manifest entry.
int	equalityDeleteFileCount()
long	equalityDeleteRecordCount()
<T> T	get(int pos, java.lang.Class<T> javaClass)
java.lang.Long	lastUpdatedAt()
java.lang.Long	lastUpdatedSnapshotId()
void	liveEntry(ContentFile<?> file, Snapshot snapshot)	Updates the partition stats from the data/delete file.
StructLike	partition()
int	positionDeleteFileCount()
long	positionDeleteRecordCount()
<T> void	set(int pos, T value)
int	size()
int	specId()
long	totalDataFileSizeInBytes()
long	totalRecordCount()

Methods inherited from class java.lang.Object

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

Constructor Detail

PartitionStats

public PartitionStats(StructLike partition,
                      int specId)

Method Detail

partition

public StructLike partition()

specId

public int specId()

dataRecordCount

public long dataRecordCount()

dataFileCount

public int dataFileCount()

totalDataFileSizeInBytes

public long totalDataFileSizeInBytes()

positionDeleteRecordCount

public long positionDeleteRecordCount()

positionDeleteFileCount

public int positionDeleteFileCount()

equalityDeleteRecordCount

public long equalityDeleteRecordCount()

equalityDeleteFileCount

public int equalityDeleteFileCount()

totalRecordCount

public long totalRecordCount()

lastUpdatedAt

public java.lang.Long lastUpdatedAt()

lastUpdatedSnapshotId

public java.lang.Long lastUpdatedSnapshotId()

liveEntry

public void liveEntry(ContentFile<?> file,
                      Snapshot snapshot)

Updates the partition stats from the data/delete file.

Parameters:

file - the ContentFile from the manifest entry.

snapshot - the snapshot corresponding to the live entry.

deletedEntry

public void deletedEntry(Snapshot snapshot)

Updates the modified time and snapshot ID for the deleted manifest entry.

Parameters:

snapshot - the snapshot corresponding to the deleted manifest entry.

appendStats

public void appendStats(PartitionStats entry)

Appends statistics from given entry to current entry.

Parameters:

entry - the entry from which statistics will be sourced.

size

public int size()

Specified by:

size in interface StructLike

get

public <T> T get(int pos,
                 java.lang.Class<T> javaClass)

Specified by:

get in interface StructLike

set

public <T> void set(int pos,
                    T value)

Specified by:

set in interface StructLike