Package org.apache.iceberg
Class FilesTable
- java.lang.Object
-
- org.apache.iceberg.BaseMetadataTable
-
- org.apache.iceberg.FilesTable
-
- All Implemented Interfaces:
java.io.Serializable,HasTableOperations,Table
public class FilesTable extends BaseMetadataTable
ATableimplementation that exposes a table's files as rows.- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classFilesTable.FilesTableScan
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ExpireSnapshotsexpireSnapshots()Create a newexpire APIto manage snapshots in this table and commit.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.ReplaceSortOrderreplaceSortOrder()Create a newReplaceSortOrderto set the table sort order and commit the change.RewriteManifestsrewriteManifests()Create a newrewrite manifests APIto replace manifests for this table and commit.Schemaschema()Return theschemafor this table.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.UpdatePartitionSpecupdateSpec()Create a newUpdatePartitionSpecto alter the partition spec of this table and commit the change.UpdateStatisticsupdateStatistics()Create a newupdate table statistics APIto add or remove statistics files in this table.-
Methods inherited from class org.apache.iceberg.BaseMetadataTable
currentSnapshot, encryption, history, io, location, locationProvider, name, operations, properties, refresh, refs, schemas, snapshot, snapshots, sortOrder, sortOrders, spec, specs, statisticsFiles, table, toString
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.apache.iceberg.Table
newBatchScan, newFastAppend, newIncrementalAppendScan, newIncrementalChangelogScan, snapshot
-
-
-
-
Method Detail
-
newScan
public 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
-
schema
public Schema schema()
Description copied from interface:TableReturn theschemafor this table.- Returns:
- this table's schema
-
updateSchema
public UpdateSchema updateSchema()
Description copied from interface:TableCreate a newUpdateSchemato alter the columns of this table and commit the change.- Specified by:
updateSchemain interfaceTable- Returns:
- a new
UpdateSchema
-
updateSpec
public UpdatePartitionSpec updateSpec()
Description copied from interface:TableCreate a newUpdatePartitionSpecto alter the partition spec of this table and commit the change.- Specified by:
updateSpecin interfaceTable- Returns:
- a new
UpdatePartitionSpec
-
updateProperties
public UpdateProperties updateProperties()
Description copied from interface:TableCreate a newUpdatePropertiesto update table properties and commit the changes.- Specified by:
updatePropertiesin interfaceTable- Returns:
- a new
UpdateProperties
-
replaceSortOrder
public ReplaceSortOrder replaceSortOrder()
Description copied from interface:TableCreate a newReplaceSortOrderto set the table sort order and commit the change.- Specified by:
replaceSortOrderin interfaceTable- Returns:
- a new
ReplaceSortOrder
-
updateLocation
public UpdateLocation updateLocation()
Description copied from interface:TableCreate a newUpdateLocationto update table location and commit the changes.- Specified by:
updateLocationin interfaceTable- Returns:
- a new
UpdateLocation
-
newAppend
public AppendFiles newAppend()
Description copied from interface:TableCreate a newappend APIto add files to this table and commit.- Specified by:
newAppendin interfaceTable- Returns:
- a new
AppendFiles
-
newRewrite
public RewriteFiles newRewrite()
Description copied from interface:TableCreate a newrewrite APIto replace files in this table and commit.- Specified by:
newRewritein interfaceTable- Returns:
- a new
RewriteFiles
-
rewriteManifests
public RewriteManifests rewriteManifests()
Description copied from interface:TableCreate a newrewrite manifests APIto replace manifests for this table and commit.- Specified by:
rewriteManifestsin interfaceTable- Returns:
- a new
RewriteManifests
-
newOverwrite
public OverwriteFiles newOverwrite()
Description copied from interface:TableCreate a newoverwrite APIto overwrite files by a filter expression.- Specified by:
newOverwritein interfaceTable- Returns:
- a new
OverwriteFiles
-
newRowDelta
public RowDelta newRowDelta()
Description copied from interface:TableCreate a newrow-level delta APIto remove or replace rows in existing data files.- Specified by:
newRowDeltain interfaceTable- Returns:
- a new
RowDelta
-
newReplacePartitions
public 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 interfaceTable- Returns:
- a new
ReplacePartitions
-
newDelete
public DeleteFiles newDelete()
Description copied from interface:TableCreate a newdelete APIto replace files in this table and commit.- Specified by:
newDeletein interfaceTable- Returns:
- a new
DeleteFiles
-
updateStatistics
public UpdateStatistics updateStatistics()
Description copied from interface:TableCreate a newupdate table statistics APIto add or remove statistics files in this table.- Specified by:
updateStatisticsin interfaceTable- Returns:
- a new
UpdateStatistics
-
expireSnapshots
public ExpireSnapshots expireSnapshots()
Description copied from interface:TableCreate a newexpire APIto manage snapshots in this table and commit.- Specified by:
expireSnapshotsin interfaceTable- Returns:
- a new
ExpireSnapshots
-
manageSnapshots
public ManageSnapshots manageSnapshots()
Description copied from interface:TableCreate a newmanage snapshots APIto manage snapshots in this table and commit.- Specified by:
manageSnapshotsin interfaceTable- Returns:
- a new
ManageSnapshots
-
newTransaction
public Transaction newTransaction()
Description copied from interface:TableCreate a newtransaction APIto commit multiple table operations at once.- Specified by:
newTransactionin interfaceTable- Returns:
- a new
Transaction
-
-