public class LookupFileStoreTable extends DelegatedFileStoreTable
FileStoreTable
for lookup table.Modifier and Type | Class and Description |
---|---|
static class |
LookupFileStoreTable.LookupStreamScanMode
Inner stream scan mode for lookup table.
|
wrapped
Constructor and Description |
---|
LookupFileStoreTable(FileStoreTable wrapped,
List<String> joinKeys) |
LookupFileStoreTable(FileStoreTable wrapped,
LookupFileStoreTable.LookupStreamScanMode lookupScanMode) |
Modifier and Type | Method and Description |
---|---|
FileStoreTable |
copy(Map<String,String> dynamicOptions)
Copy this table with adding dynamic options.
|
FileStoreTable |
copy(TableSchema newTableSchema) |
FileStoreTable |
copyWithLatestSchema()
TODO: this method is weird, old options will overwrite new options.
|
FileStoreTable |
copyWithoutTimeTravel(Map<String,String> dynamicOptions)
Doesn't change table schema even when there exists time travel scan options.
|
InnerTableRead |
newRead() |
StreamDataTableScan |
newStreamScan() |
FileStoreTable |
switchToBranch(String branchName)
Get
DataTable with branch identified by branchName . |
branchManager, catalogEnvironment, coreOptions, createBranch, createBranch, createRowKeyExtractor, createTag, createTag, createTag, createTag, deleteBranch, deleteTag, equals, fastForward, fileIO, fullName, indexManifestFileReader, latestSnapshotId, location, manifestFileReader, manifestListReader, name, newCommit, newExpireChangelog, newExpireSnapshots, newLocalTableQuery, newScan, newSnapshotReader, newWrite, newWrite, newWriteSelector, renameTag, replaceTag, rollbackTo, rollbackTo, schema, setManifestCache, snapshot, snapshotManager, statistics, store, supportStreamingReadOverwrite, tagManager, wrapped
clone, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
bucketMode, bucketSpec, comment, options, partitionKeys, primaryKeys, rowType
newBatchWriteBuilder, newReadBuilder, newStreamWriteBuilder
deleteBranches, deleteTags
public LookupFileStoreTable(FileStoreTable wrapped, List<String> joinKeys)
public LookupFileStoreTable(FileStoreTable wrapped, LookupFileStoreTable.LookupStreamScanMode lookupScanMode)
public InnerTableRead newRead()
newRead
in interface InnerTable
newRead
in class DelegatedFileStoreTable
public StreamDataTableScan newStreamScan()
newStreamScan
in interface InnerTable
newStreamScan
in class DelegatedFileStoreTable
public FileStoreTable copy(Map<String,String> dynamicOptions)
Table
public FileStoreTable copy(TableSchema newTableSchema)
public FileStoreTable copyWithoutTimeTravel(Map<String,String> dynamicOptions)
FileStoreTable
public FileStoreTable copyWithLatestSchema()
FileStoreTable
public FileStoreTable switchToBranch(String branchName)
FileStoreTable
DataTable
with branch identified by branchName
. Note that this method
does not keep dynamic options in current table.Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.