Package org.apache.iceberg
Class ManifestsTable
- java.lang.Object
- 
- org.apache.iceberg.ManifestsTable
 
- 
- 
Constructor SummaryConstructors Constructor Description ManifestsTable(TableOperations ops, Table table)
 - 
Method SummaryAll Methods Instance Methods Concrete Methods Modifier and Type Method Description SnapshotcurrentSnapshot()Get the currentsnapshotfor this table, or null if there are no snapshots.EncryptionManagerencryption()ExpireSnapshotsexpireSnapshots()Create a newexpire APIto manage snapshots in this table and commit.java.util.List<HistoryEntry>history()Get the snapshot history of this table.FileIOio()java.lang.Stringlocation()Return the table's base location.LocationProviderlocationProvider()ManageSnapshotsmanageSnapshots()Create a newmanage snapshots APIto manage snapshots in this table and commit.AppendFilesnewAppend()Create a newappend APIto add files to this table and commit.DeleteFilesnewDelete()Create a newdelete APIto replace files in this table and commit.OverwriteFilesnewOverwrite()Create a newoverwrite APIto overwrite files by a filter expression.ReplacePartitionsnewReplacePartitions()Not recommended: Create a newreplace partitions APIto dynamically overwrite partitions in the table with new data.RewriteFilesnewRewrite()Create a newrewrite APIto replace files in this table and commit.RowDeltanewRowDelta()Create a newrow-level delta APIto remove or replace rows in existing data files.TableScannewScan()Create a newscanfor this table.TransactionnewTransaction()Create a newtransaction APIto commit multiple table operations at once.java.util.Map<java.lang.String,java.lang.String>properties()Return a map of string properties for this table.voidrefresh()Refresh the current table metadata.RewriteManifestsrewriteManifests()Create a newrewrite manifests APIto replace manifests for this table and commit.Rollbackrollback()Create a newrollback APIto roll back to a previous snapshot and commit.Schemaschema()Return theschemafor this table.Snapshotsnapshot(long snapshotId)Get thesnapshotof this table with the given id, or null if there is no matching snapshot.java.lang.Iterable<Snapshot>snapshots()Get thesnapshotsof this table.PartitionSpecspec()Return thepartition specfor this table.java.util.Map<java.lang.Integer,PartitionSpec>specs()Return a map ofpartition specsfor this table.protected DataTasktask(TableScan scan)java.lang.StringtoString()UpdateLocationupdateLocation()Create a newUpdateLocationto update table location and commit the changes.UpdatePropertiesupdateProperties()Create a newUpdatePropertiesto update table properties and commit the changes.UpdateSchemaupdateSchema()Create a newUpdateSchemato alter the columns of this table and commit the change.- 
Methods inherited from class java.lang.Objectclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 - 
Methods inherited from interface org.apache.iceberg.TablenewFastAppend
 
- 
 
- 
- 
- 
Constructor Detail- 
ManifestsTablepublic ManifestsTable(TableOperations ops, Table table) 
 
- 
 - 
Method Detail- 
newScanpublic TableScan newScan() Description copied from interface:TableCreate a newscanfor this table.Once a table scan is created, it can be refined to project columns and filter data. - Returns:
- a table scan for this table
 
 - 
schemapublic Schema schema() Description copied from interface:TableReturn theschemafor this table.- Returns:
- this table's schema
 
 - 
iopublic FileIO io() 
 - 
locationpublic java.lang.String location() Description copied from interface:TableReturn the table's base location.
 - 
encryptionpublic EncryptionManager encryption() - Specified by:
- encryptionin interface- Table
- Returns:
- an EncryptionManagerto encrypt and decrypt data files.
 
 - 
locationProviderpublic LocationProvider locationProvider() - Specified by:
- locationProviderin interface- Table
- Returns:
- a LocationProviderto provide locations for new data files
 
 - 
refreshpublic void refresh() Description copied from interface:TableRefresh the current table metadata.
 - 
specpublic PartitionSpec spec() Description copied from interface:TableReturn thepartition specfor this table.
 - 
specspublic java.util.Map<java.lang.Integer,PartitionSpec> specs() Description copied from interface:TableReturn a map ofpartition specsfor this table.
 - 
propertiespublic java.util.Map<java.lang.String,java.lang.String> properties() Description copied from interface:TableReturn a map of string properties for this table.- Specified by:
- propertiesin interface- Table
- Returns:
- this table's properties map
 
 - 
currentSnapshotpublic Snapshot currentSnapshot() Description copied from interface:TableGet the currentsnapshotfor this table, or null if there are no snapshots.- Specified by:
- currentSnapshotin interface- Table
- Returns:
- the current table Snapshot.
 
 - 
snapshotspublic java.lang.Iterable<Snapshot> snapshots() Description copied from interface:TableGet thesnapshotsof this table.
 - 
snapshotpublic Snapshot snapshot(long snapshotId) Description copied from interface:TableGet thesnapshotof this table with the given id, or null if there is no matching snapshot.
 - 
historypublic java.util.List<HistoryEntry> history() Description copied from interface:TableGet the snapshot history of this table.- Specified by:
- historyin interface- Table
- Returns:
- a list of history entries
 
 - 
updateSchemapublic UpdateSchema updateSchema() Description copied from interface:TableCreate a newUpdateSchemato alter the columns of this table and commit the change.- Specified by:
- updateSchemain interface- Table
- Returns:
- a new UpdateSchema
 
 - 
updatePropertiespublic UpdateProperties updateProperties() Description copied from interface:TableCreate a newUpdatePropertiesto update table properties and commit the changes.- Specified by:
- updatePropertiesin interface- Table
- Returns:
- a new UpdateProperties
 
 - 
updateLocationpublic UpdateLocation updateLocation() Description copied from interface:TableCreate a newUpdateLocationto update table location and commit the changes.- Specified by:
- updateLocationin interface- Table
- Returns:
- a new UpdateLocation
 
 - 
newAppendpublic AppendFiles newAppend() Description copied from interface:TableCreate a newappend APIto add files to this table and commit.- Specified by:
- newAppendin interface- Table
- Returns:
- a new AppendFiles
 
 - 
newRewritepublic RewriteFiles newRewrite() Description copied from interface:TableCreate a newrewrite APIto replace files in this table and commit.- Specified by:
- newRewritein interface- Table
- Returns:
- a new RewriteFiles
 
 - 
rewriteManifestspublic RewriteManifests rewriteManifests() Description copied from interface:TableCreate a newrewrite manifests APIto replace manifests for this table and commit.- Specified by:
- rewriteManifestsin interface- Table
- Returns:
- a new RewriteManifests
 
 - 
newOverwritepublic OverwriteFiles newOverwrite() Description copied from interface:TableCreate a newoverwrite APIto overwrite files by a filter expression.- Specified by:
- newOverwritein interface- Table
- Returns:
- a new OverwriteFiles
 
 - 
newRowDeltapublic RowDelta newRowDelta() Description copied from interface:TableCreate a newrow-level delta APIto remove or replace rows in existing data files.- Specified by:
- newRowDeltain interface- Table
- Returns:
- a new RowDelta
 
 - 
newReplacePartitionspublic ReplacePartitions newReplacePartitions() Description copied from interface:TableNot recommended: Create a newreplace partitions APIto dynamically overwrite partitions in the table with new data.This is provided to implement SQL compatible with Hive table operations but is not recommended. Instead, use the overwrite APIto explicitly overwrite data.- Specified by:
- newReplacePartitionsin interface- Table
- Returns:
- a new ReplacePartitions
 
 - 
newDeletepublic DeleteFiles newDelete() Description copied from interface:TableCreate a newdelete APIto replace files in this table and commit.- Specified by:
- newDeletein interface- Table
- Returns:
- a new DeleteFiles
 
 - 
expireSnapshotspublic ExpireSnapshots expireSnapshots() Description copied from interface:TableCreate a newexpire APIto manage snapshots in this table and commit.- Specified by:
- expireSnapshotsin interface- Table
- Returns:
- a new ExpireSnapshots
 
 - 
rollbackpublic Rollback rollback() Description copied from interface:TableCreate a newrollback APIto roll back to a previous snapshot and commit.
 - 
manageSnapshotspublic ManageSnapshots manageSnapshots() Description copied from interface:TableCreate a newmanage snapshots APIto manage snapshots in this table and commit.- Specified by:
- manageSnapshotsin interface- Table
- Returns:
- a new ManageSnapshots
 
 - 
newTransactionpublic Transaction newTransaction() Description copied from interface:TableCreate a newtransaction APIto commit multiple table operations at once.- Specified by:
- newTransactionin interface- Table
- Returns:
- a new Transaction
 
 - 
toStringpublic java.lang.String toString() - Overrides:
- toStringin class- java.lang.Object
 
 
- 
 
-