Uses of Interface
org.apache.paimon.catalog.Catalog.Loader

Packages that use Catalog.Loader

Package	Description
org.apache.paimon.flink.action
org.apache.paimon.flink.compact
org.apache.paimon.flink.sink
org.apache.paimon.flink.sink.cdc
org.apache.paimon.flink.source
org.apache.paimon.flink.source.operator

Uses of Catalog.Loader in org.apache.paimon.flink.action

Methods in org.apache.paimon.flink.action that return Catalog.Loader

Modifier and Type	Method and Description
protected Catalog.Loader	ActionBase.catalogLoader()

Uses of Catalog.Loader in org.apache.paimon.flink.compact

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

Constructor and Description
MultiAwareBucketTableScan(Catalog.Loader catalogLoader, Pattern includingPattern, Pattern excludingPattern, Pattern databasePattern, boolean isStreaming, AtomicBoolean isRunning)
MultiTableScanBase(Catalog.Loader catalogLoader, Pattern includingPattern, Pattern excludingPattern, Pattern databasePattern, boolean isStreaming, AtomicBoolean isRunning)
MultiUnawareBucketTableScan(Catalog.Loader catalogLoader, Pattern includingPattern, Pattern excludingPattern, Pattern databasePattern, boolean isStreaming, AtomicBoolean isRunning)

Uses of Catalog.Loader in org.apache.paimon.flink.sink

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

Constructor and Description
AppendOnlyMultiTableCompactionWorkerOperator(Catalog.Loader catalogLoader, String commitUser, Options options)
CombinedTableCompactorSink(Catalog.Loader catalogLoader, Options options)
MultiTablesStoreCompactOperator(Catalog.Loader catalogLoader, String initialCommitUser, org.apache.flink.streaming.api.environment.CheckpointConfig checkpointConfig, boolean isStreaming, boolean ignorePreviousFiles, Options options)
StoreMultiCommitter(Catalog.Loader catalogLoader, Committer.Context context)
StoreMultiCommitter(Catalog.Loader catalogLoader, Committer.Context context, boolean ignoreEmptyCommit, Map<String,String> dynamicOptions)

Uses of Catalog.Loader in org.apache.paimon.flink.sink.cdc

Fields in org.apache.paimon.flink.sink.cdc declared as Catalog.Loader

Modifier and Type	Field and Description
protected Catalog.Loader	UpdatedDataFieldsProcessFunctionBase.catalogLoader

Methods in org.apache.paimon.flink.sink.cdc with parameters of type Catalog.Loader

Modifier and Type	Method and Description
RichCdcSinkBuilder	RichCdcSinkBuilder.catalogLoader(Catalog.Loader catalogLoader)
static org.apache.flink.streaming.api.datastream.DataStream<CdcMultiplexRecord>	CaseSensitiveUtils.cdcMultiplexRecordConvert(Catalog.Loader catalogLoader, org.apache.flink.streaming.api.datastream.DataStream<CdcMultiplexRecord> input)
static org.apache.flink.streaming.api.datastream.DataStream<CdcRecord>	CaseSensitiveUtils.cdcRecordConvert(Catalog.Loader catalogLoader, org.apache.flink.streaming.api.datastream.DataStream<CdcRecord> input)
FlinkCdcSyncDatabaseSinkBuilder<T>	FlinkCdcSyncDatabaseSinkBuilder.withCatalogLoader(Catalog.Loader catalogLoader)
RichCdcSinkBuilder	RichCdcSinkBuilder.withCatalogLoader(Catalog.Loader catalogLoader) Deprecated. Use RichCdcSinkBuilder.catalogLoader.
CdcSinkBuilder<T>	CdcSinkBuilder.withCatalogLoader(Catalog.Loader catalogLoader)

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

Constructor and Description
CdcDynamicTableParsingProcessFunction(String database, Catalog.Loader catalogLoader, EventParser.Factory<T> parserFactory)
CdcMultiplexRecordChannelComputer(Catalog.Loader catalogLoader)
CdcRecordStoreMultiWriteOperator(Catalog.Loader catalogLoader, StoreSinkWrite.WithWriteBufferProvider storeSinkWriteProvider, String initialCommitUser, Options options)
FlinkCdcMultiTableSink(Catalog.Loader catalogLoader, double commitCpuCores, MemorySize commitHeapMemory, boolean commitChaining, String commitUser)
MultiTableUpdatedDataFieldsProcessFunction(Catalog.Loader catalogLoader)
UpdatedDataFieldsProcessFunction(SchemaManager schemaManager, Identifier identifier, Catalog.Loader catalogLoader)
UpdatedDataFieldsProcessFunctionBase(Catalog.Loader catalogLoader)

Uses of Catalog.Loader in org.apache.paimon.flink.source

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

Constructor and Description
CombinedTableCompactorSourceBuilder(Catalog.Loader catalogLoader, Pattern databasePattern, Pattern includingPattern, Pattern excludingPattern, long monitorInterval)

Uses of Catalog.Loader in org.apache.paimon.flink.source.operator

Fields in org.apache.paimon.flink.source.operator declared as Catalog.Loader

Modifier and Type	Field and Description
protected Catalog.Loader	CombinedCompactorSourceFunction.catalogLoader

Methods in org.apache.paimon.flink.source.operator with parameters of type Catalog.Loader

Modifier and Type	Method and Description
static org.apache.flink.streaming.api.datastream.DataStream<MultiTableUnawareAppendCompactionTask>	CombinedUnawareBatchSourceFunction.buildSource(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env, String name, Catalog.Loader catalogLoader, Pattern includingPattern, Pattern excludingPattern, Pattern databasePattern, java.time.Duration partitionIdleTime)
static org.apache.flink.streaming.api.datastream.DataStream<MultiTableUnawareAppendCompactionTask>	CombinedUnawareStreamingSourceFunction.buildSource(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env, String name, Catalog.Loader catalogLoader, Pattern includingPattern, Pattern excludingPattern, Pattern databasePattern, long monitorInterval)
static org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData>	CombinedAwareBatchSourceFunction.buildSource(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env, String name, org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.RowData> typeInfo, Catalog.Loader catalogLoader, Pattern includingPattern, Pattern excludingPattern, Pattern databasePattern, java.time.Duration partitionIdleTime)
static org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData>	CombinedAwareStreamingSourceFunction.buildSource(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env, String name, org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.RowData> typeInfo, Catalog.Loader catalogLoader, Pattern includingPattern, Pattern excludingPattern, Pattern databasePattern, long monitorInterval)

Constructors in org.apache.paimon.flink.source.operator with parameters of type Catalog.Loader

Constructor and Description
CombinedAwareBatchSourceFunction(Catalog.Loader catalogLoader, Pattern includingPattern, Pattern excludingPattern, Pattern databasePattern)
CombinedAwareStreamingSourceFunction(Catalog.Loader catalogLoader, Pattern includingPattern, Pattern excludingPattern, Pattern databasePattern, long monitorInterval)
CombinedCompactorSourceFunction(Catalog.Loader catalogLoader, Pattern includingPattern, Pattern excludingPattern, Pattern databasePattern, boolean isStreaming)
CombinedUnawareBatchSourceFunction(Catalog.Loader catalogLoader, Pattern includingPattern, Pattern excludingPattern, Pattern databasePattern)
CombinedUnawareStreamingSourceFunction(Catalog.Loader catalogLoader, Pattern includingPattern, Pattern excludingPattern, Pattern databasePattern, long monitorInterval)
MultiTablesReadOperator(Catalog.Loader catalogLoader, boolean isStreaming)
MultiTablesReadOperator(Catalog.Loader catalogLoader, boolean isStreaming, java.time.Duration partitionIdleTime)
MultiUnawareTablesReadOperator(Catalog.Loader catalogLoader, java.time.Duration partitionIdleTime)