Package 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 Description static classGenericManifestFile.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, KEY_METADATA, LENGTH, MANIFEST_CONTENT, MIN_SEQUENCE_NUMBER, PARTITION_SUMMARIES, PARTITION_SUMMARY_TYPE, PATH, SCHEMA, SEQUENCE_NUMBER, SNAPSHOT_ID, SPEC_ID
-
-
Constructor Summary
Constructors Constructor Description 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, java.nio.ByteBuffer keyMetadata)GenericManifestFile(org.apache.avro.Schema avroSchema)Used by Avro reflection to instantiate this class when reading manifest files.
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.IntegeraddedFilesCount()Returns the number of files with status ADDED in the manifest file.java.lang.LongaddedRowsCount()Returns the total number of rows in all files with status ADDED in the manifest file.ManifestContentcontent()Returns the content stored in the manifest; either DATA or DELETES.ManifestFilecopy()Copies thismanifest file.static GenericManifestFile.CopyBuildercopyOf(ManifestFile manifestFile)java.lang.IntegerdeletedFilesCount()Returns the number of files with status DELETED in the manifest file.java.lang.LongdeletedRowsCount()Returns the total number of rows in all files with status DELETED in the manifest file.booleanequals(java.lang.Object other)java.lang.IntegerexistingFilesCount()Returns the number of files with status EXISTING in the manifest file.java.lang.LongexistingRowsCount()Returns the total number of rows in all files with status EXISTING in the manifest file.java.lang.Objectget(int i)<T> Tget(int pos, java.lang.Class<T> javaClass)org.apache.avro.SchemagetSchema()inthashCode()java.nio.ByteBufferkeyMetadata()Returns metadata about how this manifest file is encrypted, or null if the file is stored in plain text.java.lang.LonglazyLength()longlength()Returns length of the manifest file.longminSequenceNumber()Returns the lowest data sequence number of any live file in the manifest.java.util.List<ManifestFile.PartitionFieldSummary>partitions()Returns a list ofpartition field summaries.intpartitionSpecId()Returns iD of thePartitionSpecused to write the manifest file.java.lang.Stringpath()Returns fully qualified path to the file, suitable for constructing a Hadoop Path.voidput(int i, java.lang.Object v)longsequenceNumber()Returns the sequence number of the commit that added the manifest file.<T> voidset(int i, T value)intsize()java.lang.LongsnapshotId()Returns iD of the snapshot that added the manifest file to table metadata.java.lang.StringtoString()-
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
-
-
-
-
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, java.nio.ByteBuffer keyMetadata)
-
-
Method Detail
-
path
public java.lang.String path()
Description copied from interface:ManifestFileReturns fully qualified path to the file, suitable for constructing a Hadoop Path.- Specified by:
pathin interfaceManifestFile
-
lazyLength
public java.lang.Long lazyLength()
-
length
public long length()
Description copied from interface:ManifestFileReturns length of the manifest file.- Specified by:
lengthin interfaceManifestFile
-
partitionSpecId
public int partitionSpecId()
Description copied from interface:ManifestFileReturns iD of thePartitionSpecused to write the manifest file.- Specified by:
partitionSpecIdin interfaceManifestFile
-
content
public ManifestContent content()
Description copied from interface:ManifestFileReturns the content stored in the manifest; either DATA or DELETES.- Specified by:
contentin interfaceManifestFile
-
sequenceNumber
public long sequenceNumber()
Description copied from interface:ManifestFileReturns the sequence number of the commit that added the manifest file.- Specified by:
sequenceNumberin interfaceManifestFile
-
minSequenceNumber
public long minSequenceNumber()
Description copied from interface:ManifestFileReturns the lowest data sequence number of any live file in the manifest.- Specified by:
minSequenceNumberin interfaceManifestFile
-
snapshotId
public java.lang.Long snapshotId()
Description copied from interface:ManifestFileReturns iD of the snapshot that added the manifest file to table metadata.- Specified by:
snapshotIdin interfaceManifestFile
-
addedFilesCount
public java.lang.Integer addedFilesCount()
Description copied from interface:ManifestFileReturns the number of files with status ADDED in the manifest file.- Specified by:
addedFilesCountin interfaceManifestFile
-
addedRowsCount
public java.lang.Long addedRowsCount()
Description copied from interface:ManifestFileReturns the total number of rows in all files with status ADDED in the manifest file.- Specified by:
addedRowsCountin interfaceManifestFile
-
existingFilesCount
public java.lang.Integer existingFilesCount()
Description copied from interface:ManifestFileReturns the number of files with status EXISTING in the manifest file.- Specified by:
existingFilesCountin interfaceManifestFile
-
existingRowsCount
public java.lang.Long existingRowsCount()
Description copied from interface:ManifestFileReturns the total number of rows in all files with status EXISTING in the manifest file.- Specified by:
existingRowsCountin interfaceManifestFile
-
deletedFilesCount
public java.lang.Integer deletedFilesCount()
Description copied from interface:ManifestFileReturns the number of files with status DELETED in the manifest file.- Specified by:
deletedFilesCountin interfaceManifestFile
-
deletedRowsCount
public java.lang.Long deletedRowsCount()
Description copied from interface:ManifestFileReturns the total number of rows in all files with status DELETED in the manifest file.- Specified by:
deletedRowsCountin interfaceManifestFile
-
partitions
public java.util.List<ManifestFile.PartitionFieldSummary> partitions()
Description copied from interface:ManifestFileReturns a list ofpartition 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:
partitionsin interfaceManifestFile- Returns:
- a list of partition field summaries, one for each field in the manifest's spec
-
keyMetadata
public java.nio.ByteBuffer keyMetadata()
Description copied from interface:ManifestFileReturns metadata about how this manifest file is encrypted, or null if the file is stored in plain text.- Specified by:
keyMetadatain interfaceManifestFile
-
size
public int size()
- Specified by:
sizein interfaceStructLike
-
get
public <T> T get(int pos, java.lang.Class<T> javaClass)- Specified by:
getin interfaceStructLike
-
get
public java.lang.Object get(int i)
- Specified by:
getin interfaceorg.apache.avro.generic.IndexedRecord
-
set
public <T> void set(int i, T value)- Specified by:
setin interfaceStructLike
-
put
public void put(int i, java.lang.Object v)- Specified by:
putin interfaceorg.apache.avro.generic.IndexedRecord
-
copy
public ManifestFile copy()
Description copied from interface:ManifestFileCopies thismanifest file. Readers can reuse manifest file instances; use this method to make defensive copies.- Specified by:
copyin interfaceManifestFile- Returns:
- a copy of this manifest file
-
getSchema
public org.apache.avro.Schema getSchema()
- Specified by:
getSchemain interfaceorg.apache.avro.generic.GenericContainer
-
equals
public boolean equals(java.lang.Object other)
- Overrides:
equalsin classjava.lang.Object
-
hashCode
public int hashCode()
- Overrides:
hashCodein classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toStringin classjava.lang.Object
-
copyOf
public static GenericManifestFile.CopyBuilder copyOf(ManifestFile manifestFile)
-
-