public class HistoryTable extends BaseMetadataTable
Table implementation that exposes a table's history as rows.
History is based on the table's snapshot log, which logs each update to the table's current snapshot.
| Modifier and Type | Method and Description |
|---|---|
ExpireSnapshots |
expireSnapshots()
Create a new
expire API to manage snapshots in this table and commit. |
ManageSnapshots |
manageSnapshots()
Create a new
manage snapshots API to manage snapshots in this table and
commit. |
AppendFiles |
newAppend()
Create a new
append API to add files to this table and commit. |
DeleteFiles |
newDelete()
Create a new
delete API to replace files in this table and commit. |
OverwriteFiles |
newOverwrite()
Create a new
overwrite API to overwrite files by a filter expression. |
ReplacePartitions |
newReplacePartitions()
Not recommended: Create a new
replace partitions API to dynamically
overwrite partitions in the table with new data. |
RewriteFiles |
newRewrite()
Create a new
rewrite API to replace files in this table and commit. |
RowDelta |
newRowDelta()
Create a new
row-level delta API to remove or replace rows in existing data
files. |
TableScan |
newScan()
Create a new
scan for this table. |
Transaction |
newTransaction()
Create a new
transaction API to commit multiple table operations at once. |
ReplaceSortOrder |
replaceSortOrder()
Create a new
ReplaceSortOrder to set the table sort order and commit the change. |
RewriteManifests |
rewriteManifests()
Create a new
rewrite manifests API to replace manifests for this table
and commit. |
Schema |
schema()
Return the
schema for this table. |
UpdateLocation |
updateLocation()
Create a new
UpdateLocation to update table location and commit the changes. |
UpdateProperties |
updateProperties()
Create a new
UpdateProperties to update table properties and commit the changes. |
UpdateSchema |
updateSchema()
Create a new
UpdateSchema to alter the columns of this table and commit the change. |
UpdatePartitionSpec |
updateSpec()
Create a new
UpdatePartitionSpec to alter the partition spec of this table and commit
the change. |
UpdateStatistics |
updateStatistics()
Create a new
update table statistics API to add or remove statistics
files in this table. |
currentSnapshot, encryption, history, io, location, locationProvider, name, operations, properties, refresh, refs, schemas, snapshot, snapshots, sortOrder, sortOrders, spec, specs, statisticsFiles, table, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitnewBatchScan, newFastAppend, newIncrementalAppendScan, newIncrementalChangelogScan, snapshotpublic TableScan newScan()
Tablescan for this table.
Once a table scan is created, it can be refined to project columns and filter data.
public Schema schema()
Tableschema for this table.public UpdateSchema updateSchema()
TableUpdateSchema to alter the columns of this table and commit the change.updateSchema in interface TableUpdateSchemapublic UpdatePartitionSpec updateSpec()
TableUpdatePartitionSpec to alter the partition spec of this table and commit
the change.updateSpec in interface TableUpdatePartitionSpecpublic UpdateProperties updateProperties()
TableUpdateProperties to update table properties and commit the changes.updateProperties in interface TableUpdatePropertiespublic ReplaceSortOrder replaceSortOrder()
TableReplaceSortOrder to set the table sort order and commit the change.replaceSortOrder in interface TableReplaceSortOrderpublic UpdateLocation updateLocation()
TableUpdateLocation to update table location and commit the changes.updateLocation in interface TableUpdateLocationpublic AppendFiles newAppend()
Tableappend API to add files to this table and commit.newAppend in interface TableAppendFilespublic RewriteFiles newRewrite()
Tablerewrite API to replace files in this table and commit.newRewrite in interface TableRewriteFilespublic RewriteManifests rewriteManifests()
Tablerewrite manifests API to replace manifests for this table
and commit.rewriteManifests in interface TableRewriteManifestspublic OverwriteFiles newOverwrite()
Tableoverwrite API to overwrite files by a filter expression.newOverwrite in interface TableOverwriteFilespublic RowDelta newRowDelta()
Tablerow-level delta API to remove or replace rows in existing data
files.newRowDelta in interface TableRowDeltapublic ReplacePartitions newReplacePartitions()
Tablereplace partitions API to 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 API to explicitly overwrite
data.
newReplacePartitions in interface TableReplacePartitionspublic DeleteFiles newDelete()
Tabledelete API to replace files in this table and commit.newDelete in interface TableDeleteFilespublic UpdateStatistics updateStatistics()
Tableupdate table statistics API to add or remove statistics
files in this table.updateStatistics in interface TableUpdateStatisticspublic ExpireSnapshots expireSnapshots()
Tableexpire API to manage snapshots in this table and commit.expireSnapshots in interface TableExpireSnapshotspublic ManageSnapshots manageSnapshots()
Tablemanage snapshots API to manage snapshots in this table and
commit.manageSnapshots in interface TableManageSnapshotspublic Transaction newTransaction()
Tabletransaction API to commit multiple table operations at once.newTransaction in interface TableTransaction