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, MANIFEST_CONTENT, 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, ManifestContent content, 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() Returns the number of data files with status ADDED in the manifest file.
java.lang.Long	addedRowsCount() Returns the total number of rows in all data files with status ADDED in the manifest file.
ManifestContent	content() Returns the content stored in the manifest; either DATA or DELETES.
ManifestFile	copy() Copies this manifest file.
static GenericManifestFile.CopyBuilder	copyOf(ManifestFile manifestFile)
java.lang.Integer	deletedFilesCount() Returns the number of data files with status DELETED in the manifest file.
java.lang.Long	deletedRowsCount() Returns the total number of rows in all data files with status DELETED in the manifest file.
boolean	equals(java.lang.Object other)
java.lang.Integer	existingFilesCount() Returns the number of data files with status EXISTING in the manifest file.
java.lang.Long	existingRowsCount() Returns the total number of rows in all data files with status EXISTING in the manifest file.
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() Returns length of the manifest file.
long	minSequenceNumber() Returns the lowest sequence number of any data file in the manifest.
java.util.List<ManifestFile.PartitionFieldSummary>	partitions() Returns a list of partition field summaries.
int	partitionSpecId() Returns iD of the PartitionSpec used to write the manifest file.
java.lang.String	path() Returns fully qualified path to the file, suitable for constructing a Hadoop Path.
void	put(int i, java.lang.Object v)
long	sequenceNumber() Returns the sequence number of the commit that added the manifest file.
<T> void	set(int i, T value)
int	size()
java.lang.Long	snapshotId() Returns iD of the snapshot that added the manifest file to table metadata.
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,
                           ManifestContent content,
                           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()

Description copied from interface: ManifestFile

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

Specified by:

path in interface ManifestFile

lazyLength

public java.lang.Long lazyLength()

length

public long length()

Description copied from interface: ManifestFile

Returns length of the manifest file.

Specified by:

length in interface ManifestFile

partitionSpecId

public int partitionSpecId()

Description copied from interface: ManifestFile

Returns iD of the PartitionSpec used to write the manifest file.

Specified by:

partitionSpecId in interface ManifestFile

content

public ManifestContent content()

Description copied from interface: ManifestFile

Returns the content stored in the manifest; either DATA or DELETES.

Specified by:

content in interface ManifestFile

sequenceNumber

public long sequenceNumber()

Description copied from interface: ManifestFile

Returns the sequence number of the commit that added the manifest file.

Specified by:

sequenceNumber in interface ManifestFile

minSequenceNumber

public long minSequenceNumber()

Description copied from interface: ManifestFile

Returns the lowest sequence number of any data file in the manifest.

Specified by:

minSequenceNumber in interface ManifestFile

snapshotId

public java.lang.Long snapshotId()

Description copied from interface: ManifestFile

Returns iD of the snapshot that added the manifest file to table metadata.

Specified by:

snapshotId in interface ManifestFile

addedFilesCount

public java.lang.Integer addedFilesCount()

Description copied from interface: ManifestFile

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

Specified by:

addedFilesCount in interface ManifestFile

addedRowsCount

public java.lang.Long addedRowsCount()

Description copied from interface: ManifestFile

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

Specified by:

addedRowsCount in interface ManifestFile

existingFilesCount

public java.lang.Integer existingFilesCount()

Description copied from interface: ManifestFile

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

Specified by:

existingFilesCount in interface ManifestFile

existingRowsCount

public java.lang.Long existingRowsCount()

Description copied from interface: ManifestFile

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

Specified by:

existingRowsCount in interface ManifestFile

deletedFilesCount

public java.lang.Integer deletedFilesCount()

Description copied from interface: ManifestFile

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

Specified by:

deletedFilesCount in interface ManifestFile

deletedRowsCount

public java.lang.Long deletedRowsCount()

Description copied from interface: ManifestFile

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

Specified by:

deletedRowsCount in interface ManifestFile

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)