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/interfaces inherited from interface org.apache.iceberg.ManifestFile

ManifestFile.PartitionFieldSummary

Field Summary

Fields inherited from interface org.apache.iceberg.ManifestFile

SCHEMA

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 snapshotId, int addedFilesCount, int existingFilesCount, int deletedFilesCount, java.util.List<ManifestFile.PartitionFieldSummary> partitions)

Method Summary

Modifier and Type	Method and Description
java.lang.Integer	addedFilesCount()
ManifestFile	copy() Copies this manifest file.
java.lang.Integer	deletedFilesCount()
boolean	equals(java.lang.Object other)
java.lang.Integer	existingFilesCount()
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()
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)
<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 snapshotId,
                           int addedFilesCount,
                           int existingFilesCount,
                           int deletedFilesCount,
                           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

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

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

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

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