@Public public interface FormatTable extends Table
Partitioned file format table just like the standard hive format. Partitions are discovered and inferred based on directory structure.
Modifier and Type | Interface and Description |
---|---|
static class |
FormatTable.Builder
Builder for
FormatTable . |
static class |
FormatTable.Format
Currently supported formats.
|
static class |
FormatTable.FormatTableImpl
An implementation for
FormatTable . |
Modifier and Type | Method and Description |
---|---|
static FormatTable.Builder |
builder()
Create a new builder for
FormatTable . |
FormatTable |
copy(Map<String,String> dynamicOptions)
Copy this table with adding dynamic options.
|
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.
|
FormatTable.Format |
format()
Format of this table.
|
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.
|
String |
location()
Directory location in file system.
|
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 ExpireSnapshots |
newExpireChangelog() |
default ExpireSnapshots |
newExpireSnapshots()
Manually expire snapshots, parameters can be controlled independently of table options.
|
default ReadBuilder |
newReadBuilder()
Returns a new read builder.
|
default StreamWriteBuilder |
newStreamWriteBuilder()
Returns a new stream write builder.
|
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.
|
comment, deleteBranches, deleteTags, fullName, name, options, partitionKeys, primaryKeys, rowType
String location()
FormatTable.Format format()
FormatTable copy(Map<String,String> dynamicOptions)
Table
static FormatTable.Builder builder()
FormatTable
.default Optional<Statistics> statistics()
Table
statistics
in interface Table
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 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
default ReadBuilder newReadBuilder()
Table
newReadBuilder
in interface Table
default BatchWriteBuilder newBatchWriteBuilder()
Table
newBatchWriteBuilder
in interface Table
default StreamWriteBuilder newStreamWriteBuilder()
Table
newStreamWriteBuilder
in interface Table
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.