Uses of Interface
org.apache.paimon.table.FileStoreTable

Packages that use FileStoreTable

Package	Description
org.apache.paimon.append
org.apache.paimon.flink.action.cdc
org.apache.paimon.flink.clone
org.apache.paimon.flink.compact
org.apache.paimon.flink.compact.changelog
org.apache.paimon.flink.lookup
org.apache.paimon.flink.orphan
org.apache.paimon.flink.query
org.apache.paimon.flink.sink
org.apache.paimon.flink.sink.cdc
org.apache.paimon.flink.sink.index
org.apache.paimon.flink.sink.partition
org.apache.paimon.flink.sorter
org.apache.paimon.flink.source
org.apache.paimon.flink.utils
org.apache.paimon.hive.mapred
org.apache.paimon.hive.migrate
org.apache.paimon.hive.utils
org.apache.paimon.iceberg
org.apache.paimon.iceberg.manifest
org.apache.paimon.operation
org.apache.paimon.partition.actions
org.apache.paimon.privilege
org.apache.paimon.spark.sort
org.apache.paimon.table
org.apache.paimon.table.query
org.apache.paimon.table.source.snapshot
org.apache.paimon.table.system
org.apache.paimon.tag

Uses of FileStoreTable in org.apache.paimon.append

Methods in org.apache.paimon.append with parameters of type FileStoreTable

Modifier and Type	Method and Description
CommitMessage	UnawareAppendCompactionTask.doCompact(FileStoreTable table, AppendOnlyFileStoreWrite write)

Constructors in org.apache.paimon.append with parameters of type FileStoreTable

Constructor and Description
UnawareAppendTableCompactionCoordinator(FileStoreTable table)
UnawareAppendTableCompactionCoordinator(FileStoreTable table, boolean isStreaming)
UnawareAppendTableCompactionCoordinator(FileStoreTable table, boolean isStreaming, Predicate filter)

Uses of FileStoreTable in org.apache.paimon.flink.action.cdc

Fields in org.apache.paimon.flink.action.cdc declared as FileStoreTable

Modifier and Type	Field and Description
protected FileStoreTable	SyncTableActionBase.fileStoreTable

Fields in org.apache.paimon.flink.action.cdc with type parameters of type FileStoreTable

Modifier and Type	Field and Description
protected List<FileStoreTable>	SyncDatabaseActionBase.tables

Methods in org.apache.paimon.flink.action.cdc that return FileStoreTable

Modifier and Type	Method and Description
protected FileStoreTable	SynchronizationActionBase.alterTableOptions(Identifier identifier, FileStoreTable table)
FileStoreTable	SyncTableActionBase.fileStoreTable()

Methods in org.apache.paimon.flink.action.cdc with parameters of type FileStoreTable

Modifier and Type	Method and Description
protected FileStoreTable	SynchronizationActionBase.alterTableOptions(Identifier identifier, FileStoreTable table)

Uses of FileStoreTable in org.apache.paimon.flink.clone

Methods in org.apache.paimon.flink.clone with parameters of type FileStoreTable

Modifier and Type	Method and Description
static List<Path>	PickFilesUtil.getUsedFilesForLatestSnapshot(FileStoreTable table)

Uses of FileStoreTable in org.apache.paimon.flink.compact

Methods in org.apache.paimon.flink.compact with parameters of type FileStoreTable

Modifier and Type	Method and Description
void	MultiUnawareBucketTableScan.addScanTable(FileStoreTable fileStoreTable, Identifier identifier)
void	MultiAwareBucketTableScan.addScanTable(FileStoreTable fileStoreTable, Identifier identifier)

Constructors in org.apache.paimon.flink.compact with parameters of type FileStoreTable

Constructor and Description
UnawareBucketCompactionTopoBuilder(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env, String tableIdentifier, FileStoreTable table)
UnawareBucketCompactor(FileStoreTable table, String commitUser, java.util.function.Supplier<ExecutorService> lazyCompactExecutor, org.apache.flink.metrics.MetricGroup metricGroup)

Uses of FileStoreTable in org.apache.paimon.flink.compact.changelog

Methods in org.apache.paimon.flink.compact.changelog with parameters of type FileStoreTable

Modifier and Type	Method and Description
List<Committable>	ChangelogCompactTask.doCompact(FileStoreTable table)

Constructors in org.apache.paimon.flink.compact.changelog with parameters of type FileStoreTable

Constructor and Description
ChangelogCompactCoordinateOperator(FileStoreTable table)
ChangelogCompactWorkerOperator(FileStoreTable table)

Uses of FileStoreTable in org.apache.paimon.flink.lookup

Classes in org.apache.paimon.flink.lookup that implement FileStoreTable

Modifier and Type	Class and Description
class	LookupFileStoreTable FileStoreTable for lookup table.

Methods in org.apache.paimon.flink.lookup that return FileStoreTable

Modifier and Type	Method and Description
FileStoreTable	LookupFileStoreTable.copy(Map<String,String> dynamicOptions)
FileStoreTable	LookupFileStoreTable.copy(TableSchema newTableSchema)
FileStoreTable	LookupFileStoreTable.copyWithLatestSchema()
FileStoreTable	LookupFileStoreTable.copyWithoutTimeTravel(Map<String,String> dynamicOptions)
FileStoreTable	LookupFileStoreTable.switchToBranch(String branchName)

Methods in org.apache.paimon.flink.lookup with parameters of type FileStoreTable

Modifier and Type	Method and Description
static PrimaryKeyPartialLookupTable	PrimaryKeyPartialLookupTable.createLocalTable(FileStoreTable table, int[] projection, File tempPath, List<String> joinKey, Set<Integer> requireCachedBucketIds)
static PrimaryKeyPartialLookupTable	PrimaryKeyPartialLookupTable.createRemoteTable(FileStoreTable table, int[] projection, List<String> joinKey)

Constructors in org.apache.paimon.flink.lookup with parameters of type FileStoreTable

Constructor and Description
Context(FileStoreTable table, int[] projection, Predicate tablePredicate, Predicate projectedPredicate, File tempPath, List<String> joinKey, Set<Integer> requiredCachedBucketIds)
LookupFileStoreTable(FileStoreTable wrapped, List<String> joinKeys)
LookupFileStoreTable(FileStoreTable wrapped, LookupFileStoreTable.LookupStreamScanMode lookupScanMode)

Uses of FileStoreTable in org.apache.paimon.flink.orphan

Constructors in org.apache.paimon.flink.orphan with parameters of type FileStoreTable

Constructor and Description
FlinkOrphanFilesClean(FileStoreTable table, long olderThanMillis, SerializableConsumer<Path> fileCleaner, Integer parallelism)

Uses of FileStoreTable in org.apache.paimon.flink.query

Methods in org.apache.paimon.flink.query with parameters of type FileStoreTable

Modifier and Type	Method and Description
static boolean	RemoteTableQuery.isRemoteServiceAvailable(FileStoreTable table)

Uses of FileStoreTable in org.apache.paimon.flink.sink

Fields in org.apache.paimon.flink.sink declared as FileStoreTable

Modifier and Type	Field and Description
protected FileStoreTable	BatchWriteGeneratorTagOperator.table
protected FileStoreTable	FlinkSinkBuilder.table
protected FileStoreTable	TableWriteOperator.table
protected FileStoreTable	FlinkSink.table
protected FileStoreTable	UnawareBucketSink.table

Fields in org.apache.paimon.flink.sink with type parameters of type FileStoreTable

Modifier and Type	Field and Description
protected Map<Identifier,FileStoreTable>	MultiTablesStoreCompactOperator.tables

Methods in org.apache.paimon.flink.sink with parameters of type FileStoreTable

Modifier and Type	Method and Description
StoreSinkWrite	StoreSinkWrite.WithWriteBufferProvider.provide(FileStoreTable table, String commitUser, StoreSinkWriteState state, org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager, MemoryPoolFactory memoryPoolFactory, org.apache.flink.metrics.MetricGroup metricGroup) TODO: The argument list has become too complicated.
StoreSinkWrite	StoreSinkWrite.Provider.provide(FileStoreTable table, String commitUser, StoreSinkWriteState state, org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager, MemorySegmentPool memoryPool, org.apache.flink.metrics.MetricGroup metricGroup) TODO: The argument list has become too complicated.
void	StoreSinkWrite.replace(FileStoreTable newTable) Replace the internal TableWriteImpl with the one provided by newWriteProvider.
void	StoreSinkWriteImpl.replace(FileStoreTable newTable)
static org.apache.flink.streaming.api.datastream.DataStreamSink<?>	UnawareBucketCompactionSink.sink(FileStoreTable table, org.apache.flink.streaming.api.datastream.DataStream<UnawareAppendCompactionTask> input)

Constructors in org.apache.paimon.flink.sink with parameters of type FileStoreTable

Constructor and Description
AppendBypassCompactWorkerOperator(FileStoreTable table, String commitUser)
AppendCompactWorkerOperator(FileStoreTable table, String commitUser)
AppendOnlySingleTableCompactionWorkerOperator(FileStoreTable table, String commitUser)
AsyncLookupSinkWrite(FileStoreTable table, String commitUser, StoreSinkWriteState state, org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager, boolean ignorePreviousFiles, boolean waitCompaction, boolean isStreaming, MemorySegmentPool memoryPool, org.apache.flink.metrics.MetricGroup metricGroup)
BatchWriteGeneratorTagOperator(CommitterOperator<CommitT,GlobalCommitT> commitOperator, FileStoreTable table)
CompactorSink(FileStoreTable table)
CompactorSinkBuilder(FileStoreTable table)
DynamicBucketCompactSink(FileStoreTable table, Map<String,String> overwritePartition)
DynamicBucketRowWriteOperator(FileStoreTable table, StoreSinkWrite.Provider storeSinkWriteProvider, String initialCommitUser)
DynamicBucketSink(FileStoreTable table, Map<String,String> overwritePartition)
FileIndexProcessor(FileStoreTable table)
FixedBucketSink(FileStoreTable table, Map<String,String> overwritePartition, LogSinkFunction logSinkFunction)
FlinkSink(FileStoreTable table, boolean ignorePreviousFiles)
FlinkWriteSink(FileStoreTable table, Map<String,String> overwritePartition)
GlobalFullCompactionSinkWrite(FileStoreTable table, String commitUser, StoreSinkWriteState state, org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager, boolean ignorePreviousFiles, boolean waitCompaction, int deltaCommits, boolean isStreaming, MemorySegmentPool memoryPool, org.apache.flink.metrics.MetricGroup metricGroup)
RewriteFileIndexSink(FileStoreTable table)
RowDataStoreWriteOperator(FileStoreTable table, LogSinkFunction logSinkFunction, StoreSinkWrite.Provider storeSinkWriteProvider, String initialCommitUser)
RowDynamicBucketSink(FileStoreTable table, Map<String,String> overwritePartition)
RowUnawareBucketSink(FileStoreTable table, Map<String,String> overwritePartitions, LogSinkFunction logSinkFunction, Integer parallelism)
StoreCommitter(FileStoreTable table, TableCommit commit, Committer.Context context)
StoreCompactOperator(FileStoreTable table, StoreSinkWrite.Provider storeSinkWriteProvider, String initialCommitUser)
StoreSinkWriteImpl(FileStoreTable table, String commitUser, StoreSinkWriteState state, org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager, boolean ignorePreviousFiles, boolean waitCompaction, boolean isStreamingMode, MemoryPoolFactory memoryPoolFactory, org.apache.flink.metrics.MetricGroup metricGroup)
StoreSinkWriteImpl(FileStoreTable table, String commitUser, StoreSinkWriteState state, org.apache.flink.runtime.io.disk.iomanager.IOManager ioManager, boolean ignorePreviousFiles, boolean waitCompaction, boolean isStreamingMode, MemorySegmentPool memoryPool, org.apache.flink.metrics.MetricGroup metricGroup)
TableWriteOperator(FileStoreTable table, StoreSinkWrite.Provider storeSinkWriteProvider, String initialCommitUser)
UnawareBucketCompactionSink(FileStoreTable table)
UnawareBucketSink(FileStoreTable table, Map<String,String> overwritePartitions, LogSinkFunction logSinkFunction, Integer parallelism)

Uses of FileStoreTable in org.apache.paimon.flink.sink.cdc

Methods in org.apache.paimon.flink.sink.cdc that return types with arguments of type FileStoreTable

Modifier and Type	Method and Description
Map<Identifier,FileStoreTable>	CdcRecordStoreMultiWriteOperator.tables()

Method parameters in org.apache.paimon.flink.sink.cdc with type arguments of type FileStoreTable

Modifier and Type	Method and Description
FlinkCdcSyncDatabaseSinkBuilder<T>	FlinkCdcSyncDatabaseSinkBuilder.withTables(List<FileStoreTable> tables)

Constructors in org.apache.paimon.flink.sink.cdc with parameters of type FileStoreTable

Constructor and Description
CdcDynamicBucketSink(FileStoreTable table)
CdcDynamicBucketSinkBase(FileStoreTable table)
CdcDynamicBucketWriteOperator(FileStoreTable table, StoreSinkWrite.Provider storeSinkWriteProvider, String initialCommitUser)
CdcFixedBucketSink(FileStoreTable table)
CdcRecordStoreWriteOperator(FileStoreTable table, StoreSinkWrite.Provider storeSinkWriteProvider, String initialCommitUser)
CdcUnawareBucketSink(FileStoreTable table, Integer parallelism)
CdcUnawareBucketWriteOperator(FileStoreTable table, StoreSinkWrite.Provider storeSinkWriteProvider, String initialCommitUser)

Uses of FileStoreTable in org.apache.paimon.flink.sink.index

Constructors in org.apache.paimon.flink.sink.index with parameters of type FileStoreTable

Constructor and Description
GlobalDynamicBucketSink(FileStoreTable table, Map<String,String> overwritePartition)

Uses of FileStoreTable in org.apache.paimon.flink.sink.partition

Methods in org.apache.paimon.flink.sink.partition with parameters of type FileStoreTable

Modifier and Type	Method and Description
static Optional<PartitionMarkDone>	PartitionMarkDone.create(boolean isStreaming, boolean isRestored, org.apache.flink.api.common.state.OperatorStateStore stateStore, FileStoreTable table)
static Optional<ReportHmsListener>	ReportHmsListener.create(boolean isRestored, org.apache.flink.api.common.state.OperatorStateStore stateStore, FileStoreTable table)
static PartitionListeners	PartitionListeners.create(Committer.Context context, FileStoreTable table)

Constructors in org.apache.paimon.flink.sink.partition with parameters of type FileStoreTable

Constructor and Description
HmsReporter(FileStoreTable table, MetastoreClient client)

Uses of FileStoreTable in org.apache.paimon.flink.sorter

Fields in org.apache.paimon.flink.sorter declared as FileStoreTable

Modifier and Type	Field and Description
protected FileStoreTable	TableSorter.table

Methods in org.apache.paimon.flink.sorter with parameters of type FileStoreTable

Modifier and Type	Method and Description
static TableSorter	TableSorter.getSorter(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment batchTEnv, org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> origin, FileStoreTable fileStoreTable, TableSortInfo sortInfo)
static <KEY> org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData>	SortUtils.sortStreamByKey(org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> inputStream, FileStoreTable table, RowType sortKeyType, org.apache.flink.api.common.typeinfo.TypeInformation<KEY> keyTypeInformation, SerializableSupplier<Comparator<KEY>> shuffleKeyComparator, org.apache.paimon.flink.sorter.SortUtils.KeyAbstract<KEY> shuffleKeyAbstract, org.apache.paimon.flink.sorter.SortUtils.ShuffleKeyConvertor<KEY> convertor, TableSortInfo tableSortInfo) Sort the input stream by the key specified.

Constructors in org.apache.paimon.flink.sorter with parameters of type FileStoreTable

Constructor and Description
HilbertSorter(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment batchTEnv, org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> origin, FileStoreTable table, TableSortInfo tableSortInfo)
OrderSorter(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment batchTEnv, org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> origin, FileStoreTable table, TableSortInfo tableSortInfo)
TableSorter(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment batchTEnv, org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> origin, FileStoreTable table, List<String> orderColNames)
ZorderSorter(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment batchTEnv, org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> origin, FileStoreTable table, TableSortInfo sortInfo)

Uses of FileStoreTable in org.apache.paimon.flink.source

Constructors in org.apache.paimon.flink.source with parameters of type FileStoreTable

Constructor and Description
AppendBypassCoordinateOperator(FileStoreTable table, org.apache.flink.streaming.runtime.tasks.ProcessingTimeService processingTimeService)
AppendBypassCoordinateOperatorFactory(FileStoreTable table)
BucketUnawareCompactSource(FileStoreTable table, boolean isStreaming, long scanInterval, Predicate filter)
CompactorSourceBuilder(String tableIdentifier, FileStoreTable table)
RewriteFileIndexSource(FileStoreTable table, Predicate partitionPredicate)

Uses of FileStoreTable in org.apache.paimon.flink.utils

Methods in org.apache.paimon.flink.utils with parameters of type FileStoreTable

Modifier and Type	Method and Description
static Statistics	TableStatsUtil.createTableColumnStats(FileStoreTable table, org.apache.flink.table.catalog.stats.CatalogColumnStatistics columnStatistics) Create Paimon statistics from given Flink columnStatistics.
static Statistics	TableStatsUtil.createTableStats(FileStoreTable table, org.apache.flink.table.catalog.stats.CatalogTableStatistics catalogTableStatistics) create Paimon statistics.

Uses of FileStoreTable in org.apache.paimon.hive.mapred

Methods in org.apache.paimon.hive.mapred that return FileStoreTable

Modifier and Type	Method and Description
FileStoreTable	PaimonInputSplit.getTable()

Constructors in org.apache.paimon.hive.mapred with parameters of type FileStoreTable

Constructor and Description
PaimonInputSplit(String path, DataSplit split, FileStoreTable table)

Uses of FileStoreTable in org.apache.paimon.hive.migrate

Methods in org.apache.paimon.hive.migrate with parameters of type FileStoreTable

Modifier and Type	Method and Description
HiveMigrator.MigrateTask	HiveMigrator.importUnPartitionedTableTask(FileIO fileIO, org.apache.hadoop.hive.metastore.api.Table sourceTable, FileStoreTable paimonTable, Map<Path,Path> rollback)

Constructors in org.apache.paimon.hive.migrate with parameters of type FileStoreTable

Constructor and Description
MigrateTask(FileIO fileIO, String format, String location, FileStoreTable paimonTable, BinaryRow partitionRow, Path newDir, Map<Path,Path> rollback)

Uses of FileStoreTable in org.apache.paimon.hive.utils

Methods in org.apache.paimon.hive.utils that return FileStoreTable

Modifier and Type	Method and Description
static FileStoreTable	HiveUtils.createFileStoreTable(org.apache.hadoop.mapred.JobConf jobConf)

Methods in org.apache.paimon.hive.utils with parameters of type FileStoreTable

Modifier and Type	Method and Description
static org.apache.hadoop.mapred.InputSplit[]	HiveSplitGenerator.generateSplits(FileStoreTable table, org.apache.hadoop.mapred.JobConf jobConf)

Uses of FileStoreTable in org.apache.paimon.iceberg

Fields in org.apache.paimon.iceberg declared as FileStoreTable

Modifier and Type	Field and Description
protected FileStoreTable	AbstractIcebergCommitCallback.table

Methods in org.apache.paimon.iceberg with parameters of type FileStoreTable

Modifier and Type	Method and Description
IcebergMetadataCommitter	IcebergHiveMetadataCommitterFactory.create(FileStoreTable table)
IcebergMetadataCommitter	IcebergMetadataCommitterFactory.create(FileStoreTable table)

Constructors in org.apache.paimon.iceberg with parameters of type FileStoreTable

Constructor and Description
AbstractIcebergCommitCallback(FileStoreTable table, String commitUser)
AppendOnlyIcebergCommitCallback(FileStoreTable table, String commitUser)
IcebergHiveMetadataCommitter(FileStoreTable table)
PrimaryKeyIcebergCommitCallback(FileStoreTable table, String commitUser)

Uses of FileStoreTable in org.apache.paimon.iceberg.manifest

Methods in org.apache.paimon.iceberg.manifest with parameters of type FileStoreTable

Modifier and Type	Method and Description
static IcebergManifestFile	IcebergManifestFile.create(FileStoreTable table, IcebergPathFactory pathFactory)
static IcebergManifestList	IcebergManifestList.create(FileStoreTable table, IcebergPathFactory pathFactory)

Uses of FileStoreTable in org.apache.paimon.operation

Fields in org.apache.paimon.operation declared as FileStoreTable

Modifier and Type	Field and Description
protected FileStoreTable	OrphanFilesClean.table

Constructors in org.apache.paimon.operation with parameters of type FileStoreTable

Constructor and Description
LocalOrphanFilesClean(FileStoreTable table)
LocalOrphanFilesClean(FileStoreTable table, long olderThanMillis)
LocalOrphanFilesClean(FileStoreTable table, long olderThanMillis, SerializableConsumer<Path> fileCleaner)
OrphanFilesClean(FileStoreTable table, long olderThanMillis, SerializableConsumer<Path> fileCleaner)

Uses of FileStoreTable in org.apache.paimon.partition.actions

Methods in org.apache.paimon.partition.actions with parameters of type FileStoreTable

Modifier and Type	Method and Description
static List<PartitionMarkDoneAction>	PartitionMarkDoneAction.createActions(FileStoreTable fileStoreTable, CoreOptions options)
static MetastoreClient	PartitionMarkDoneAction.createMetastoreClient(FileStoreTable table, CoreOptions options)

Uses of FileStoreTable in org.apache.paimon.privilege

Classes in org.apache.paimon.privilege that implement FileStoreTable

Modifier and Type	Class and Description
class	PrivilegedFileStoreTable FileStoreTable with privilege checks.

Methods in org.apache.paimon.privilege that return FileStoreTable

Modifier and Type	Method and Description
FileStoreTable	PrivilegedFileStoreTable.copy(Map<String,String> dynamicOptions)
FileStoreTable	PrivilegedFileStoreTable.copy(TableSchema newTableSchema)
FileStoreTable	PrivilegedFileStoreTable.copyWithLatestSchema()
FileStoreTable	PrivilegedFileStoreTable.copyWithoutTimeTravel(Map<String,String> dynamicOptions)
FileStoreTable	PrivilegedFileStoreTable.switchToBranch(String branchName)

Constructors in org.apache.paimon.privilege with parameters of type FileStoreTable

Constructor and Description
PrivilegedFileStoreTable(FileStoreTable wrapped, PrivilegeChecker privilegeChecker, Identifier identifier)

Uses of FileStoreTable in org.apache.paimon.spark.sort

Fields in org.apache.paimon.spark.sort declared as FileStoreTable

Modifier and Type	Field and Description
protected FileStoreTable	TableSorter.table

Methods in org.apache.paimon.spark.sort with parameters of type FileStoreTable

Modifier and Type	Method and Description
static TableSorter	TableSorter.getSorter(FileStoreTable table, TableSorter.OrderType orderType, List<String> orderColumns)

Constructors in org.apache.paimon.spark.sort with parameters of type FileStoreTable

Constructor and Description
HilbertSorter(FileStoreTable table, List<String> orderColumns)
OrderSorter(FileStoreTable table, List<String> orderColNames)
TableSorter(FileStoreTable table, List<String> orderColNames)
ZorderSorter(FileStoreTable table, List<String> zOrderColNames)

Uses of FileStoreTable in org.apache.paimon.table

Classes in org.apache.paimon.table that implement FileStoreTable

Modifier and Type	Class and Description
class	DelegatedFileStoreTable Delegated FileStoreTable.
class	FallbackReadFileStoreTable A FileStoreTable which mainly read from the current branch.

Fields in org.apache.paimon.table declared as FileStoreTable

Modifier and Type	Field and Description
protected FileStoreTable	DelegatedFileStoreTable.wrapped

Methods in org.apache.paimon.table that return FileStoreTable

Modifier and Type	Method and Description
FileStoreTable	FileStoreTable.copy(Map<String,String> dynamicOptions)
FileStoreTable	FallbackReadFileStoreTable.copy(Map<String,String> dynamicOptions)
FileStoreTable	FileStoreTable.copy(TableSchema newTableSchema)
FileStoreTable	FallbackReadFileStoreTable.copy(TableSchema newTableSchema)
FileStoreTable	FileStoreTable.copyWithLatestSchema() TODO: this method is weird, old options will overwrite new options.
FileStoreTable	FallbackReadFileStoreTable.copyWithLatestSchema()
FileStoreTable	FileStoreTable.copyWithoutTimeTravel(Map<String,String> dynamicOptions) Doesn't change table schema even when there exists time travel scan options.
FileStoreTable	FallbackReadFileStoreTable.copyWithoutTimeTravel(Map<String,String> dynamicOptions)
static FileStoreTable	FileStoreTableFactory.create(CatalogContext context)
static FileStoreTable	FileStoreTableFactory.create(FileIO fileIO, Options options)
static FileStoreTable	FileStoreTableFactory.create(FileIO fileIO, Path path)
static FileStoreTable	FileStoreTableFactory.create(FileIO fileIO, Path tablePath, TableSchema tableSchema)
static FileStoreTable	FileStoreTableFactory.create(FileIO fileIO, Path tablePath, TableSchema tableSchema, CatalogEnvironment catalogEnvironment)
static FileStoreTable	FileStoreTableFactory.create(FileIO fileIO, Path tablePath, TableSchema tableSchema, Options dynamicOptions, CatalogEnvironment catalogEnvironment)
static FileStoreTable	FileStoreTableFactory.createWithoutFallbackBranch(FileIO fileIO, Path tablePath, TableSchema tableSchema, Options dynamicOptions, CatalogEnvironment catalogEnvironment)
FileStoreTable	FileStoreTable.switchToBranch(String branchName) Get DataTable with branch identified by branchName.
FileStoreTable	FallbackReadFileStoreTable.switchToBranch(String branchName)
FileStoreTable	DelegatedFileStoreTable.wrapped()

Constructors in org.apache.paimon.table with parameters of type FileStoreTable

Constructor and Description
DelegatedFileStoreTable(FileStoreTable wrapped)
FallbackReadFileStoreTable(FileStoreTable wrapped, FileStoreTable fallback)

Uses of FileStoreTable in org.apache.paimon.table.query

Constructors in org.apache.paimon.table.query with parameters of type FileStoreTable

Constructor and Description
LocalTableQuery(FileStoreTable table)

Uses of FileStoreTable in org.apache.paimon.table.source.snapshot

Methods in org.apache.paimon.table.source.snapshot with parameters of type FileStoreTable

Modifier and Type	Method and Description
static Snapshot	TimeTravelUtil.resolveSnapshot(FileStoreTable table)

Uses of FileStoreTable in org.apache.paimon.table.system

Fields in org.apache.paimon.table.system with type parameters of type FileStoreTable

Modifier and Type	Field and Description
static Map<String,java.util.function.Function<FileStoreTable,Table>>	SystemTableLoader.SYSTEM_TABLE_LOADERS

Methods in org.apache.paimon.table.system with parameters of type FileStoreTable

Modifier and Type	Method and Description
static Table	SystemTableLoader.load(String type, FileStoreTable dataTable)

Constructors in org.apache.paimon.table.system with parameters of type FileStoreTable

Constructor and Description
AggregationFieldsTable(FileStoreTable dataTable)
AuditLogTable(FileStoreTable wrapped)
BranchesTable(FileStoreTable dataTable)
BucketsTable(FileStoreTable storeTable)
CompactBucketsTable(FileStoreTable wrapped, boolean isContinuous)
CompactBucketsTable(FileStoreTable wrapped, boolean isContinuous, String databaseName)
ConsumersTable(FileStoreTable dataTable)
FileMonitorTable(FileStoreTable wrapped)
FilesTable(FileStoreTable storeTable)
ManifestsTable(FileStoreTable dataTable)
OptionsTable(FileStoreTable dataTable)
PartitionsTable(FileStoreTable storeTable)
ReadOptimizedTable(FileStoreTable wrapped)
SchemasTable(FileStoreTable dataTable)
SnapshotsTable(FileIO fileIO, Path location, FileStoreTable dataTable, String branchName)
SnapshotsTable(FileStoreTable dataTable)
StatisticTable(FileStoreTable dataTable)
TagsTable(FileStoreTable dataTable)

Uses of FileStoreTable in org.apache.paimon.tag

Methods in org.apache.paimon.tag with parameters of type FileStoreTable

Modifier and Type	Method and Description
Map<String,String>	TagPreview.timeTravel(FileStoreTable table, String tag)