Modifier and Type | Method and Description |
---|---|
protected Catalog.Loader |
ActionBase.catalogLoader() |
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) |
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) |
Modifier and Type | Field and Description |
---|---|
protected Catalog.Loader |
UpdatedDataFieldsProcessFunctionBase.catalogLoader |
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) |
RichCdcSinkBuilder |
RichCdcSinkBuilder.withCatalogLoader(Catalog.Loader catalogLoader)
Deprecated.
|
CdcSinkBuilder<T> |
CdcSinkBuilder.withCatalogLoader(Catalog.Loader catalogLoader) |
FlinkCdcSyncDatabaseSinkBuilder<T> |
FlinkCdcSyncDatabaseSinkBuilder.withCatalogLoader(Catalog.Loader catalogLoader) |
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) |
Constructor and Description |
---|
CombinedTableCompactorSourceBuilder(Catalog.Loader catalogLoader,
Pattern databasePattern,
Pattern includingPattern,
Pattern excludingPattern,
long monitorInterval) |
Modifier and Type | Field and Description |
---|---|
protected Catalog.Loader |
CombinedCompactorSourceFunction.catalogLoader |
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) |
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) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.