public class ManifestFileBean extends java.lang.Object implements ManifestFile
ManifestFile.PartitionFieldSummary
Modifier and Type | Field and Description |
---|---|
static org.apache.spark.sql.Encoder<ManifestFileBean> |
ENCODER |
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 and Description |
---|
ManifestFileBean() |
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 . |
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.
|
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.Long |
getAddedSnapshotId() |
java.lang.Integer |
getContent() |
java.lang.Long |
getLength() |
java.lang.Integer |
getPartitionSpecId() |
java.lang.String |
getPath() |
java.nio.ByteBuffer |
keyMetadata()
Returns metadata about how this manifest file is encrypted, or null if the file is stored in
plain text.
|
long |
length()
Returns length of the manifest file.
|
long |
minSequenceNumber()
Returns the lowest data sequence number of any live 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.
|
long |
sequenceNumber()
Returns the sequence number of the commit that added the manifest file.
|
void |
setAddedSnapshotId(java.lang.Long addedSnapshotId) |
void |
setContent(java.lang.Integer content) |
void |
setLength(java.lang.Long length) |
void |
setPartitionSpecId(java.lang.Integer partitionSpecId) |
void |
setPath(java.lang.String path) |
java.lang.Long |
snapshotId()
Returns iD of the snapshot that added the manifest file to table metadata.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
hasAddedFiles, hasDeletedFiles, hasExistingFiles, schema
public static final org.apache.spark.sql.Encoder<ManifestFileBean> ENCODER
public java.lang.String getPath()
public void setPath(java.lang.String path)
public java.lang.Long getLength()
public void setLength(java.lang.Long length)
public java.lang.Integer getPartitionSpecId()
public void setPartitionSpecId(java.lang.Integer partitionSpecId)
public java.lang.Long getAddedSnapshotId()
public void setAddedSnapshotId(java.lang.Long addedSnapshotId)
public java.lang.Integer getContent()
public void setContent(java.lang.Integer content)
public java.lang.String path()
ManifestFile
path
in interface ManifestFile
public long length()
ManifestFile
length
in interface ManifestFile
public int partitionSpecId()
ManifestFile
PartitionSpec
used to write the manifest file.partitionSpecId
in interface ManifestFile
public ManifestContent content()
ManifestFile
content
in interface ManifestFile
public long sequenceNumber()
ManifestFile
sequenceNumber
in interface ManifestFile
public long minSequenceNumber()
ManifestFile
minSequenceNumber
in interface ManifestFile
public java.lang.Long snapshotId()
ManifestFile
snapshotId
in interface ManifestFile
public java.lang.Integer addedFilesCount()
ManifestFile
addedFilesCount
in interface ManifestFile
public java.lang.Long addedRowsCount()
ManifestFile
addedRowsCount
in interface ManifestFile
public java.lang.Integer existingFilesCount()
ManifestFile
existingFilesCount
in interface ManifestFile
public java.lang.Long existingRowsCount()
ManifestFile
existingRowsCount
in interface ManifestFile
public java.lang.Integer deletedFilesCount()
ManifestFile
deletedFilesCount
in interface ManifestFile
public java.lang.Long deletedRowsCount()
ManifestFile
deletedRowsCount
in interface ManifestFile
public java.util.List<ManifestFile.PartitionFieldSummary> partitions()
ManifestFile
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.
partitions
in interface ManifestFile
public java.nio.ByteBuffer keyMetadata()
ManifestFile
keyMetadata
in interface ManifestFile
public ManifestFile copy()
ManifestFile
manifest file
. Readers can reuse manifest file instances; use
this method to make defensive copies.copy
in interface ManifestFile