Package org.apache.iceberg

Class BasePartitionStatistics

java.lang.Object

org.apache.iceberg.avro.SupportsIndexProjection

org.apache.iceberg.BasePartitionStatistics

All Implemented Interfaces:

Serializable, PartitionStatistics, StructLike

public class BasePartitionStatistics
extends SupportsIndexProjection
implements PartitionStatistics

See Also:

• Serialized Form

Field Summary

Fields inherited from interface org.apache.iceberg.PartitionStatistics

DATA_FILE_COUNT, DATA_FILE_COUNT_POSITION, DATA_RECORD_COUNT, DATA_RECORD_COUNT_POSITION, DV_COUNT, DV_COUNT_POSITION, EMPTY_PARTITION_FIELD, EQUALITY_DELETE_FILE_COUNT, EQUALITY_DELETE_FILE_COUNT_POSITION, EQUALITY_DELETE_RECORD_COUNT, EQUALITY_DELETE_RECORD_COUNT_POSITION, LAST_UPDATED_AT, LAST_UPDATED_AT_POSITION, LAST_UPDATED_SNAPSHOT_ID, LAST_UPDATED_SNAPSHOT_ID_POSITION, PARTITION_POSITION, POSITION_DELETE_FILE_COUNT, POSITION_DELETE_FILE_COUNT_POSITION, POSITION_DELETE_RECORD_COUNT, POSITION_DELETE_RECORD_COUNT_POSITION, SPEC_ID, SPEC_ID_POSITION, TOTAL_DATA_FILE_SIZE_IN_BYTES, TOTAL_DATA_FILE_SIZE_IN_BYTES_POSITION, TOTAL_RECORD_COUNT, TOTAL_RECORD_COUNT_POSITION

Method Summary

Modifier and Type	Method	Description
Integer	dataFileCount()	Returns the number of data files in the partition
Long	dataRecordCount()	Returns the number of data records in the partition
Integer	dvCount()	Returns the number of delete vectors in the partition
Integer	equalityDeleteFileCount()	Returns the number of equality delete files in the partition
Long	equalityDeleteRecordCount()	Returns the number of equality delete records in the partition
protected <T> T	internalGet(int pos, Class<T> javaClass)
protected <T> void	internalSet(int pos, T value)
Long	lastUpdatedAt()	Returns the timestamp in milliseconds when the partition was last updated
Long	lastUpdatedSnapshotId()	Returns the ID of the snapshot that last updated this partition
StructLike	partition()	Returns the partition of these partition statistics
Integer	positionDeleteFileCount()	Returns the number of positional delete files in the partition
Long	positionDeleteRecordCount()	Returns the number of positional delete records in the partition.
Integer	specId()	Returns the spec ID of the partition of these partition statistics
Long	totalDataFileSizeInBytes()	Returns the total size of data files in bytes in the partition
Long	totalRecords()	Returns the total number of records in the partition

Methods inherited from class org.apache.iceberg.avro.SupportsIndexProjection

get, set, size

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.iceberg.StructLike

get, set, size

Method Details

partition

public StructLike partition()

Description copied from interface: PartitionStatistics

Returns the partition of these partition statistics

Specified by:

partition in interface PartitionStatistics

specId

public Integer specId()

Description copied from interface: PartitionStatistics

Returns the spec ID of the partition of these partition statistics

Specified by:

specId in interface PartitionStatistics

dataRecordCount

public Long dataRecordCount()

Description copied from interface: PartitionStatistics

Returns the number of data records in the partition

Specified by:

dataRecordCount in interface PartitionStatistics

dataFileCount

public Integer dataFileCount()

Description copied from interface: PartitionStatistics

Returns the number of data files in the partition

Specified by:

dataFileCount in interface PartitionStatistics

totalDataFileSizeInBytes

public Long totalDataFileSizeInBytes()

Description copied from interface: PartitionStatistics

Returns the total size of data files in bytes in the partition

Specified by:

totalDataFileSizeInBytes in interface PartitionStatistics

positionDeleteRecordCount

public Long positionDeleteRecordCount()

Description copied from interface: PartitionStatistics

Returns the number of positional delete records in the partition. Also includes dv record count as per spec

Specified by:

positionDeleteRecordCount in interface PartitionStatistics

positionDeleteFileCount

public Integer positionDeleteFileCount()

Description copied from interface: PartitionStatistics

Returns the number of positional delete files in the partition

Specified by:

positionDeleteFileCount in interface PartitionStatistics

equalityDeleteRecordCount

public Long equalityDeleteRecordCount()

Description copied from interface: PartitionStatistics

Returns the number of equality delete records in the partition

Specified by:

equalityDeleteRecordCount in interface PartitionStatistics

equalityDeleteFileCount

public Integer equalityDeleteFileCount()

Description copied from interface: PartitionStatistics

Returns the number of equality delete files in the partition

Specified by:

equalityDeleteFileCount in interface PartitionStatistics

totalRecords

public Long totalRecords()

Description copied from interface: PartitionStatistics

Returns the total number of records in the partition

Specified by:

totalRecords in interface PartitionStatistics

lastUpdatedAt

public Long lastUpdatedAt()

Description copied from interface: PartitionStatistics

Returns the timestamp in milliseconds when the partition was last updated

Specified by:

lastUpdatedAt in interface PartitionStatistics

lastUpdatedSnapshotId

public Long lastUpdatedSnapshotId()

Description copied from interface: PartitionStatistics

Returns the ID of the snapshot that last updated this partition

Specified by:

lastUpdatedSnapshotId in interface PartitionStatistics

dvCount

public Integer dvCount()

Description copied from interface: PartitionStatistics

Returns the number of delete vectors in the partition

Specified by:

dvCount in interface PartitionStatistics

internalGet

protected <T> T internalGet(int pos,
 Class<T> javaClass)

Specified by:

internalGet in class SupportsIndexProjection

internalSet

protected <T> void internalSet(int pos,
 T value)

Specified by:

internalSet in class SupportsIndexProjection