public interface Table
Modifier and Type | Method and Description |
---|---|
Snapshot |
currentSnapshot()
Get the current
snapshot for this table. |
ExpireSnapshots |
expireSnapshots()
Create a new
expire API to manage snapshots in this table and commit. |
java.lang.String |
location()
Return the table's base location.
|
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. |
default AppendFiles |
newFastAppend()
Create a new
append API to add files to 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. |
TableScan |
newScan()
Create a new
scan for this table. |
Transaction |
newTransaction()
Create a new
transaction API to 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.
|
void |
refresh()
Refresh the current table metadata.
|
Rollback |
rollback()
Create a new
rollback API to roll back to a previous snapshot and commit. |
Schema |
schema()
Return the
schema for this table. |
java.lang.Iterable<Snapshot> |
snapshots()
Get the
snapshots of this table. |
PartitionSpec |
spec()
Return the
partition spec for this table. |
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. |
void refresh()
TableScan newScan()
scan
for this table.
Once a table scan is created, it can be refined to project columns and filter data.
PartitionSpec spec()
partition spec
for this table.java.util.Map<java.lang.String,java.lang.String> properties()
java.lang.String location()
Snapshot currentSnapshot()
snapshot
for this table.java.lang.Iterable<Snapshot> snapshots()
snapshots
of this table.UpdateSchema updateSchema()
UpdateSchema
to alter the columns of this table and commit the change.UpdateSchema
UpdateProperties updateProperties()
UpdateProperties
to update table properties and commit the changes.UpdateProperties
AppendFiles newAppend()
append API
to add files to this table and commit.AppendFiles
default AppendFiles newFastAppend()
append API
to add files to this table and commit.
Using this method signals to the underlying implementation that the append should not perform extra work in order to commit quickly. Fast appends are not recommended for normal writes because the fast commit may cause split planning to slow down over time.
Implementations may not support fast appends, in which case this will return the same appender
as newAppend()
.
AppendFiles
RewriteFiles newRewrite()
rewrite API
to replace files in this table and commit.RewriteFiles
OverwriteFiles newOverwrite()
overwrite API
to overwrite files by a filter expression.OverwriteFiles
ReplacePartitions newReplacePartitions()
replace 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.
ReplacePartitions
DeleteFiles newDelete()
delete API
to replace files in this table and commit.DeleteFiles
ExpireSnapshots expireSnapshots()
expire API
to manage snapshots in this table and commit.ExpireSnapshots
Rollback rollback()
rollback API
to roll back to a previous snapshot and commit.Rollback
Transaction newTransaction()
transaction API
to commit multiple table operations at once.Transaction