org.apache.iceberg

Class GenericManifestFile

java.lang.Object

org.apache.iceberg.GenericManifestFile

All Implemented Interfaces:

java.io.Serializable, org.apache.avro.generic.GenericContainer, org.apache.avro.generic.IndexedRecord, org.apache.avro.specific.SpecificData.SchemaConstructable, ManifestFile, StructLike

public class GenericManifestFile
extends java.lang.Object
implements ManifestFile, StructLike, org.apache.avro.generic.IndexedRecord, org.apache.avro.specific.SpecificData.SchemaConstructable, java.io.Serializable

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	GenericManifestFile.CopyBuilder

Nested classes/interfaces inherited from interface org.apache.iceberg.ManifestFile

ManifestFile.PartitionFieldSummary

Field Summary

Fields inherited from interface org.apache.iceberg.ManifestFile

ADDED_FILES_COUNT, ADDED_ROWS_COUNT, DELETED_FILES_COUNT, DELETED_ROWS_COUNT, EXISTING_FILES_COUNT, EXISTING_ROWS_COUNT, LENGTH, MIN_SEQUENCE_NUMBER, PARTITION_SUMMARIES, PARTITION_SUMMARY_TYPE, PATH, SCHEMA, SEQUENCE_NUMBER, SNAPSHOT_ID, SPEC_ID

Constructor Summary

Constructors

Constructor and Description
GenericManifestFile(org.apache.avro.Schema avroSchema) Used by Avro reflection to instantiate this class when reading manifest files.
GenericManifestFile(java.lang.String path, long length, int specId, long sequenceNumber, long minSequenceNumber, java.lang.Long snapshotId, int addedFilesCount, long addedRowsCount, int existingFilesCount, long existingRowsCount, int deletedFilesCount, long deletedRowsCount, java.util.List<ManifestFile.PartitionFieldSummary> partitions)

Method Summary

Modifier and Type	Method and Description
java.lang.Integer	addedFilesCount()
java.lang.Long	addedRowsCount()
ManifestFile	copy() Copies this manifest file.
static GenericManifestFile.CopyBuilder	copyOf(ManifestFile manifestFile)
java.lang.Integer	deletedFilesCount()
java.lang.Long	deletedRowsCount()
boolean	equals(java.lang.Object other)
java.lang.Integer	existingFilesCount()
java.lang.Long	existingRowsCount()
java.lang.Object	get(int i)
<T> T	get(int pos, java.lang.Class<T> javaClass)
org.apache.avro.Schema	getSchema()
int	hashCode()
java.lang.Long	lazyLength()
long	length()
long	minSequenceNumber()
java.util.List<ManifestFile.PartitionFieldSummary>	partitions() Returns a list of partition field summaries.
int	partitionSpecId()
java.lang.String	path()
void	put(int i, java.lang.Object v)
long	sequenceNumber()
<T> void	set(int i, T value)
int	size()
java.lang.Long	snapshotId()
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.iceberg.ManifestFile

hasAddedFiles, hasDeletedFiles, hasExistingFiles, schema

Constructor Detail

GenericManifestFile

public GenericManifestFile(org.apache.avro.Schema avroSchema)

Used by Avro reflection to instantiate this class when reading manifest files.

GenericManifestFile

public GenericManifestFile(java.lang.String path,
                           long length,
                           int specId,
                           long sequenceNumber,
                           long minSequenceNumber,
                           java.lang.Long snapshotId,
                           int addedFilesCount,
                           long addedRowsCount,
                           int existingFilesCount,
                           long existingRowsCount,
                           int deletedFilesCount,
                           long deletedRowsCount,
                           java.util.List<ManifestFile.PartitionFieldSummary> partitions)

Method Detail

path

public java.lang.String path()

Specified by:

path in interface ManifestFile

Returns:

fully qualified path to the file, suitable for constructing a Hadoop Path

lazyLength

public java.lang.Long lazyLength()

length

public long length()

Specified by:

length in interface ManifestFile

Returns:

length of the manifest file

partitionSpecId

public int partitionSpecId()

Specified by:

partitionSpecId in interface ManifestFile

Returns:

ID of the PartitionSpec used to write the manifest file

sequenceNumber

public long sequenceNumber()

Specified by:

sequenceNumber in interface ManifestFile

Returns:

the sequence number of the commit that added the manifest file

minSequenceNumber

public long minSequenceNumber()

Specified by:

minSequenceNumber in interface ManifestFile

Returns:

the lowest sequence number of any data file in the manifest

snapshotId

public java.lang.Long snapshotId()

Specified by:

snapshotId in interface ManifestFile

Returns:

ID of the snapshot that added the manifest file to table metadata

addedFilesCount

public java.lang.Integer addedFilesCount()

Specified by:

addedFilesCount in interface ManifestFile

Returns:

the number of data files with status ADDED in the manifest file

addedRowsCount

public java.lang.Long addedRowsCount()

Specified by:

addedRowsCount in interface ManifestFile

Returns:

the total number of rows in all data files with status ADDED in the manifest file

existingFilesCount

public java.lang.Integer existingFilesCount()

Specified by:

existingFilesCount in interface ManifestFile

Returns:

the number of data files with status EXISTING in the manifest file

existingRowsCount

public java.lang.Long existingRowsCount()

Specified by:

existingRowsCount in interface ManifestFile

Returns:

the total number of rows in all data files with status EXISTING in the manifest file

deletedFilesCount

public java.lang.Integer deletedFilesCount()

Specified by:

deletedFilesCount in interface ManifestFile

Returns:

the number of data files with status DELETED in the manifest file

deletedRowsCount

public java.lang.Long deletedRowsCount()

Specified by:

deletedRowsCount in interface ManifestFile

Returns:

the total number of rows in all data files with status DELETED in the manifest file

partitions

public java.util.List<ManifestFile.PartitionFieldSummary> partitions()

Description copied from interface: ManifestFile

Returns a list of partition field summaries.

Each summary corresponds to a field in the manifest file's partition spec, by ordinal. For example, the partition spec [ ts_day=date(ts), type=identity(type) ] will have 2 summaries. The first summary is for the ts_day partition field and the second is for the type partition field.

Specified by:

partitions in interface ManifestFile

Returns:

a list of partition field summaries, one for each field in the manifest's spec

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

get

public java.lang.Object get(int i)

Specified by:

get in interface org.apache.avro.generic.IndexedRecord

set

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

Specified by:

set in interface StructLike

put

public void put(int i,
                java.lang.Object v)

Specified by:

put in interface org.apache.avro.generic.IndexedRecord

copy

public ManifestFile copy()

Description copied from interface: ManifestFile

Copies this manifest file. Readers can reuse manifest file instances; use this method to make defensive copies.

Specified by:

copy in interface ManifestFile

Returns:

a copy of this manifest file

getSchema

public org.apache.avro.Schema getSchema()

Specified by:

getSchema in interface org.apache.avro.generic.GenericContainer

equals

public boolean equals(java.lang.Object other)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

copyOf

public static GenericManifestFile.CopyBuilder copyOf(ManifestFile manifestFile)