org.apache.paimon.flink.lookup

Class LookupFileStoreTable

java.lang.Object

org.apache.paimon.table.DelegatedFileStoreTable

org.apache.paimon.flink.lookup.LookupFileStoreTable

All Implemented Interfaces:

Serializable, DataTable, FileStoreTable, InnerTable, Table

public class LookupFileStoreTable
extends DelegatedFileStoreTable

FileStoreTable for lookup table.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	LookupFileStoreTable.LookupStreamScanMode Inner stream scan mode for lookup table.

Field Summary

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

wrapped

Constructor Summary

Constructors

Constructor and Description
LookupFileStoreTable(FileStoreTable wrapped, List<String> joinKeys)
LookupFileStoreTable(FileStoreTable wrapped, LookupFileStoreTable.LookupStreamScanMode lookupScanMode)

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()
StreamDataTableScan	newStreamScan()
FileStoreTable	switchToBranch(String branchName) Get DataTable with branch identified by branchName.

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

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, schemaManager, setManifestCache, setSnapshotCache, 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, 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

LookupFileStoreTable

public LookupFileStoreTable(FileStoreTable wrapped,
                            List<String> joinKeys)

LookupFileStoreTable

public LookupFileStoreTable(FileStoreTable wrapped,
                            LookupFileStoreTable.LookupStreamScanMode lookupScanMode)

Method Detail

newRead

public InnerTableRead newRead()

Specified by:

newRead in interface InnerTable

Overrides:

newRead in class DelegatedFileStoreTable

newStreamScan

public StreamDataTableScan newStreamScan()

Specified by:

newStreamScan in interface InnerTable

Overrides:

newStreamScan in class DelegatedFileStoreTable

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.