public interface ReadonlyTable extends InnerTable
Modifier and Type | Method and Description |
---|---|
default Optional<String> |
comment()
Optional comment of this table.
|
default void |
createBranch(String branchName)
Create an empty branch.
|
default void |
createBranch(String branchName,
String tagName)
Create a branch from given tag.
|
default void |
createTag(String tagName)
Create a tag from latest snapshot.
|
default void |
createTag(String tagName,
java.time.Duration timeRetained) |
default void |
createTag(String tagName,
long fromSnapshotId)
Create a tag from given snapshot.
|
default void |
createTag(String tagName,
long fromSnapshotId,
java.time.Duration timeRetained) |
default void |
deleteBranch(String branchName)
Delete a branch by branchName.
|
default void |
deleteTag(String tagName)
Delete a tag by name.
|
default void |
fastForward(String branchName)
Merge a branch to main branch.
|
default SimpleFileReader<IndexManifestEntry> |
indexManifestFileReader()
Reader to read index manifest entry from index manifest file.
|
default OptionalLong |
latestSnapshotId()
Get the latest snapshot id for this table, or empty if there are no snapshots.
|
default SimpleFileReader<ManifestEntry> |
manifestFileReader()
Reader to read manifest entry from manifest file.
|
default SimpleFileReader<ManifestFileMeta> |
manifestListReader()
Reader to read manifest file meta from manifest list file.
|
default BatchWriteBuilder |
newBatchWriteBuilder()
Returns a new batch write builder.
|
default InnerTableCommit |
newCommit(String commitUser) |
default ExpireSnapshots |
newExpireChangelog() |
default ExpireSnapshots |
newExpireSnapshots()
Manually expire snapshots, parameters can be controlled independently of table options.
|
default StreamDataTableScan |
newStreamScan() |
default StreamWriteBuilder |
newStreamWriteBuilder()
Returns a new stream write builder.
|
default InnerTableWrite |
newWrite(String commitUser) |
default Optional<WriteSelector> |
newWriteSelector() |
default Map<String,String> |
options()
Options of this table.
|
default List<String> |
partitionKeys()
Partition keys of this table.
|
default void |
renameTag(String tagName,
String targetTagName) |
default void |
replaceTag(String tagName,
Long fromSnapshotId,
java.time.Duration timeRetained)
Replace a tag with new snapshot id and new time retained.
|
default void |
rollbackTo(long snapshotId)
Rollback table's state to a specific snapshot.
|
default void |
rollbackTo(String tagName)
Rollback table's state to a specific tag.
|
default Snapshot |
snapshot(long snapshotId)
Get the
Snapshot from snapshot id. |
default Optional<Statistics> |
statistics()
Optional statistics of this table.
|
newRead, newReadBuilder, newScan
copy, deleteBranches, deleteTags, fullName, name, primaryKeys, rowType
default List<String> partitionKeys()
Table
partitionKeys
in interface Table
default Map<String,String> options()
Table
default Optional<String> comment()
Table
default Optional<Statistics> statistics()
Table
statistics
in interface Table
default BatchWriteBuilder newBatchWriteBuilder()
Table
newBatchWriteBuilder
in interface InnerTable
newBatchWriteBuilder
in interface Table
default StreamWriteBuilder newStreamWriteBuilder()
Table
newStreamWriteBuilder
in interface InnerTable
newStreamWriteBuilder
in interface Table
default Optional<WriteSelector> newWriteSelector()
newWriteSelector
in interface InnerTable
default InnerTableWrite newWrite(String commitUser)
newWrite
in interface InnerTable
default InnerTableCommit newCommit(String commitUser)
newCommit
in interface InnerTable
default StreamDataTableScan newStreamScan()
newStreamScan
in interface InnerTable
default OptionalLong latestSnapshotId()
Table
latestSnapshotId
in interface Table
default Snapshot snapshot(long snapshotId)
Table
Snapshot
from snapshot id.default SimpleFileReader<ManifestFileMeta> manifestListReader()
Table
manifestListReader
in interface Table
default SimpleFileReader<ManifestEntry> manifestFileReader()
Table
manifestFileReader
in interface Table
default SimpleFileReader<IndexManifestEntry> indexManifestFileReader()
Table
indexManifestFileReader
in interface Table
default void rollbackTo(long snapshotId)
Table
rollbackTo
in interface Table
default void createTag(String tagName, long fromSnapshotId)
Table
default void createTag(String tagName, long fromSnapshotId, java.time.Duration timeRetained)
default void createTag(String tagName)
Table
default void createTag(String tagName, java.time.Duration timeRetained)
default void replaceTag(String tagName, Long fromSnapshotId, java.time.Duration timeRetained)
Table
replaceTag
in interface Table
default void deleteTag(String tagName)
Table
default void rollbackTo(String tagName)
Table
rollbackTo
in interface Table
default void createBranch(String branchName)
Table
createBranch
in interface Table
default void createBranch(String branchName, String tagName)
Table
createBranch
in interface Table
default void deleteBranch(String branchName)
Table
deleteBranch
in interface Table
default void fastForward(String branchName)
Table
fastForward
in interface Table
default ExpireSnapshots newExpireSnapshots()
Table
newExpireSnapshots
in interface Table
default ExpireSnapshots newExpireChangelog()
newExpireChangelog
in interface Table
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.