Uses of Interface
org.apache.paimon.catalog.CatalogLoader

Packages that use CatalogLoader

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 CatalogLoader in org.apache.paimon.flink.action

Methods in org.apache.paimon.flink.action that return CatalogLoader

Modifier and Type	Method and Description
protected CatalogLoader	ActionBase.catalogLoader()

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

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

Constructor and Description
MultiAwareBucketTableScan(CatalogLoader catalogLoader, Pattern includingPattern, Pattern excludingPattern, Pattern databasePattern, boolean isStreaming)
MultiTableScanBase(CatalogLoader catalogLoader, Pattern includingPattern, Pattern excludingPattern, Pattern databasePattern, boolean isStreaming)
MultiUnawareBucketTableScan(CatalogLoader catalogLoader, Pattern includingPattern, Pattern excludingPattern, Pattern databasePattern, boolean isStreaming)

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

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

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

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

Fields in org.apache.paimon.flink.sink.cdc declared as CatalogLoader

Modifier and Type	Field and Description
protected CatalogLoader	UpdatedDataFieldsProcessFunctionBase.catalogLoader

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

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

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

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

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

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

Constructor and Description
CombinedTableCompactorSourceBuilder(CatalogLoader catalogLoader, Pattern databasePattern, Pattern includingPattern, Pattern excludingPattern, long monitorInterval)

Uses of CatalogLoader in org.apache.paimon.flink.source.operator

Fields in org.apache.paimon.flink.source.operator declared as CatalogLoader

Modifier and Type	Field and Description
protected CatalogLoader	CombinedCompactorSource.catalogLoader

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

Modifier and Type	Method and Description
static org.apache.flink.streaming.api.datastream.DataStream<MultiTableUnawareAppendCompactionTask>	CombinedUnawareBatchSource.buildSource(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env, String name, CatalogLoader catalogLoader, Pattern includingPattern, Pattern excludingPattern, Pattern databasePattern, java.time.Duration partitionIdleTime)
static org.apache.flink.streaming.api.datastream.DataStream<MultiTableUnawareAppendCompactionTask>	CombinedUnawareStreamingSource.buildSource(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env, String name, CatalogLoader catalogLoader, Pattern includingPattern, Pattern excludingPattern, Pattern databasePattern, long monitorInterval)
static org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData>	CombinedAwareBatchSource.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, CatalogLoader 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>	CombinedAwareStreamingSource.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, CatalogLoader catalogLoader, Pattern includingPattern, Pattern excludingPattern, Pattern databasePattern, long monitorInterval)

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

Constructor and Description
CombinedAwareBatchSource(CatalogLoader catalogLoader, Pattern includingPattern, Pattern excludingPattern, Pattern databasePattern)
CombinedAwareStreamingSource(CatalogLoader catalogLoader, Pattern includingPattern, Pattern excludingPattern, Pattern databasePattern, long monitorInterval)
CombinedCompactorSource(CatalogLoader catalogLoader, Pattern includingPattern, Pattern excludingPattern, Pattern databasePattern, boolean isStreaming)
CombinedUnawareBatchSource(CatalogLoader catalogLoader, Pattern includingPattern, Pattern excludingPattern, Pattern databasePattern)
CombinedUnawareStreamingSource(CatalogLoader catalogLoader, Pattern includingPattern, Pattern excludingPattern, Pattern databasePattern, long monitorInterval)
MultiTablesReadOperator(CatalogLoader catalogLoader, boolean isStreaming)
MultiTablesReadOperator(CatalogLoader catalogLoader, boolean isStreaming, java.time.Duration partitionIdleTime)
MultiUnawareTablesReadOperator(CatalogLoader catalogLoader, java.time.Duration partitionIdleTime)