@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, rowTypeString location()
FormatTable.Format format()
FormatTable copy(Map<String,String> dynamicOptions)
Tablestatic FormatTable.Builder builder()
FormatTable.default Optional<Statistics> statistics()
Tablestatistics in interface Tabledefault OptionalLong latestSnapshotId()
TablelatestSnapshotId in interface Tabledefault Snapshot snapshot(long snapshotId)
TableSnapshot from snapshot id.default SimpleFileReader<ManifestFileMeta> manifestListReader()
TablemanifestListReader in interface Tabledefault SimpleFileReader<ManifestEntry> manifestFileReader()
TablemanifestFileReader in interface Tabledefault SimpleFileReader<IndexManifestEntry> indexManifestFileReader()
TableindexManifestFileReader in interface Tabledefault void rollbackTo(long snapshotId)
TablerollbackTo in interface Tabledefault void createTag(String tagName, long fromSnapshotId)
Tabledefault void createTag(String tagName, long fromSnapshotId, java.time.Duration timeRetained)
default void createTag(String tagName)
Tabledefault void createTag(String tagName, java.time.Duration timeRetained)
default void deleteTag(String tagName)
Tabledefault void rollbackTo(String tagName)
TablerollbackTo in interface Tabledefault void createBranch(String branchName)
TablecreateBranch in interface Tabledefault void createBranch(String branchName, String tagName)
TablecreateBranch in interface Tabledefault void deleteBranch(String branchName)
TabledeleteBranch in interface Tabledefault void fastForward(String branchName)
TablefastForward in interface Tabledefault ExpireSnapshots newExpireSnapshots()
TablenewExpireSnapshots in interface Tabledefault ExpireSnapshots newExpireChangelog()
newExpireChangelog in interface Tabledefault ReadBuilder newReadBuilder()
TablenewReadBuilder in interface Tabledefault BatchWriteBuilder newBatchWriteBuilder()
TablenewBatchWriteBuilder in interface Tabledefault StreamWriteBuilder newStreamWriteBuilder()
TablenewStreamWriteBuilder in interface TableCopyright © 2023–2024 The Apache Software Foundation. All rights reserved.