org.apache.paimon.table

Class FallbackReadFileStoreTable

java.lang.Object

org.apache.paimon.table.DelegatedFileStoreTable

org.apache.paimon.table.FallbackReadFileStoreTable

All Implemented Interfaces:

Serializable, DataTable, FileStoreTable, InnerTable, Table

public class FallbackReadFileStoreTable
extends DelegatedFileStoreTable

A FileStoreTable which mainly read from the current branch. However, if the current branch does not have a partition, it will read that partition from the fallback branch.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.paimon.table.DelegatedFileStoreTable

wrapped

Constructor Summary

Constructors

Constructor and Description
FallbackReadFileStoreTable(FileStoreTable wrapped, FileStoreTable fallback)

Method Summary

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()
DataTableScan	newScan()
void	setManifestCache(SegmentsCache<Path> manifestCache)
FileStoreTable	switchToBranch(String branchName) Get DataTable with branch identified by branchName.

Methods inherited from class org.apache.paimon.table.DelegatedFileStoreTable

branchManager, catalogEnvironment, changelogManager, consumerManager, coreOptions, createBranch, createBranch, createRowKeyExtractor, createTag, createTag, createTag, createTag, deleteBranch, deleteTag, equals, fastForward, fileIO, fullName, indexManifestFileReader, latestSnapshot, location, manifestFileReader, manifestListReader, name, newCommit, newExpireChangelog, newExpireSnapshots, newLocalTableQuery, newSnapshotReader, newStreamScan, newWrite, newWrite, newWriteSelector, renameTag, replaceTag, rollbackTo, rollbackTo, schema, schemaManager, setSnapshotCache, setStatsCache, snapshot, snapshotManager, statistics, store, supportStreamingReadOverwrite, tagManager, uuid, wrapped

Methods inherited from class java.lang.Object

clone, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.paimon.table.FileStoreTable

bucketMode, bucketSpec, comment, options, partitionKeys, primaryKeys, purgeFiles, rowType

Methods inherited from interface org.apache.paimon.table.InnerTable

newBatchWriteBuilder, newReadBuilder, newStreamWriteBuilder

Methods inherited from interface org.apache.paimon.table.Table

deleteBranches, deleteTags

Constructor Detail

FallbackReadFileStoreTable

public FallbackReadFileStoreTable(FileStoreTable wrapped,
                                  FileStoreTable fallback)

Method Detail

copy

public FileStoreTable copy(Map<String,String> dynamicOptions)

Description copied from interface: Table

Copy this table with adding dynamic options.

copy

public FileStoreTable copy(TableSchema newTableSchema)

copyWithoutTimeTravel

public FileStoreTable copyWithoutTimeTravel(Map<String,String> dynamicOptions)

Description copied from interface: FileStoreTable

Doesn't change table schema even when there exists time travel scan options.

copyWithLatestSchema

public FileStoreTable copyWithLatestSchema()

Description copied from interface: FileStoreTable

TODO: this method is weird, old options will overwrite new options.

switchToBranch

public FileStoreTable switchToBranch(String branchName)

Description copied from interface: FileStoreTable

Get DataTable with branch identified by branchName. Note that this method does not keep dynamic options in current table.

setManifestCache

public void setManifestCache(SegmentsCache<Path> manifestCache)

Specified by:

setManifestCache in interface FileStoreTable

Overrides:

setManifestCache in class DelegatedFileStoreTable

newScan

public DataTableScan newScan()

Specified by:

newScan in interface DataTable

Specified by:

newScan in interface InnerTable

Overrides:

newScan in class DelegatedFileStoreTable

newRead

public InnerTableRead newRead()

Specified by:

newRead in interface InnerTable

Overrides:

newRead in class DelegatedFileStoreTable