public class CompactBucketsTable extends Object implements DataTable, ReadonlyTable
Only used internally by dedicated compact job sources.
Constructor and Description |
---|
CompactBucketsTable(FileStoreTable wrapped,
boolean isContinuous) |
CompactBucketsTable(FileStoreTable wrapped,
boolean isContinuous,
String databaseName) |
Modifier and Type | Method and Description |
---|---|
BranchManager |
branchManager() |
CompactBucketsTable |
copy(Map<String,String> dynamicOptions)
Copy this table with adding dynamic options.
|
CoreOptions |
coreOptions() |
FileIO |
fileIO() |
static RowType |
getRowType() |
SimpleFileReader<IndexManifestEntry> |
indexManifestFileReader()
Reader to read index manifest entry from index manifest file.
|
OptionalLong |
latestSnapshotId()
Get the latest snapshot id for this table, or empty if there are no snapshots.
|
Path |
location() |
SimpleFileReader<ManifestEntry> |
manifestFileReader()
Reader to read manifest entry from manifest file.
|
SimpleFileReader<ManifestFileMeta> |
manifestListReader()
Reader to read manifest file meta from manifest list file.
|
String |
name()
A name to identify this table.
|
InnerTableRead |
newRead() |
DataTableScan |
newScan() |
SnapshotReader |
newSnapshotReader() |
StreamDataTableScan |
newStreamScan() |
Map<String,String> |
options()
Options of this table.
|
List<String> |
primaryKeys()
Primary keys of this table.
|
RowType |
rowType()
Returns the row type of this table.
|
SchemaManager |
schemaManager() |
Snapshot |
snapshot(long snapshotId)
Get the
Snapshot from snapshot id. |
SnapshotManager |
snapshotManager() |
DataTable |
switchToBranch(String branchName)
Get
DataTable with branch identified by branchName . |
TagManager |
tagManager() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
comment, createBranch, createBranch, createTag, createTag, createTag, createTag, deleteBranch, deleteTag, fastForward, newBatchWriteBuilder, newCommit, newExpireChangelog, newExpireSnapshots, newStreamWriteBuilder, newWrite, newWriteSelector, partitionKeys, renameTag, replaceTag, rollbackTo, rollbackTo, statistics
newReadBuilder
deleteBranches, deleteTags, fullName, uuid
public CompactBucketsTable(FileStoreTable wrapped, boolean isContinuous)
public CompactBucketsTable(FileStoreTable wrapped, boolean isContinuous, String databaseName)
public OptionalLong latestSnapshotId()
Table
latestSnapshotId
in interface ReadonlyTable
latestSnapshotId
in interface Table
public Snapshot snapshot(long snapshotId)
Table
Snapshot
from snapshot id.snapshot
in interface ReadonlyTable
snapshot
in interface Table
public SimpleFileReader<ManifestFileMeta> manifestListReader()
Table
manifestListReader
in interface ReadonlyTable
manifestListReader
in interface Table
public SimpleFileReader<ManifestEntry> manifestFileReader()
Table
manifestFileReader
in interface ReadonlyTable
manifestFileReader
in interface Table
public SimpleFileReader<IndexManifestEntry> indexManifestFileReader()
Table
indexManifestFileReader
in interface ReadonlyTable
indexManifestFileReader
in interface Table
public SnapshotManager snapshotManager()
snapshotManager
in interface DataTable
public SchemaManager schemaManager()
schemaManager
in interface DataTable
public TagManager tagManager()
tagManager
in interface DataTable
public BranchManager branchManager()
branchManager
in interface DataTable
public DataTable switchToBranch(String branchName)
DataTable
DataTable
with branch identified by branchName
. Note that this method
does not keep dynamic options in current table.switchToBranch
in interface DataTable
public RowType rowType()
Table
public Map<String,String> options()
Table
options
in interface ReadonlyTable
options
in interface Table
public List<String> primaryKeys()
Table
primaryKeys
in interface Table
public SnapshotReader newSnapshotReader()
newSnapshotReader
in interface DataTable
public DataTableScan newScan()
newScan
in interface DataTable
newScan
in interface InnerTable
public StreamDataTableScan newStreamScan()
newStreamScan
in interface InnerTable
newStreamScan
in interface ReadonlyTable
public CoreOptions coreOptions()
coreOptions
in interface DataTable
public InnerTableRead newRead()
newRead
in interface InnerTable
public CompactBucketsTable copy(Map<String,String> dynamicOptions)
Table
public static RowType getRowType()
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.