org.apache.paimon.flink.action.cdc.kafka

Class KafkaSyncDatabaseAction

java.lang.Object

org.apache.paimon.flink.action.ActionBase

org.apache.paimon.flink.action.cdc.SynchronizationActionBase

org.apache.paimon.flink.action.cdc.SyncDatabaseActionBase

org.apache.paimon.flink.action.cdc.kafka.KafkaSyncDatabaseAction

All Implemented Interfaces:

Action

public class KafkaSyncDatabaseAction
extends SyncDatabaseActionBase

Synchronize database from Kafka.

Field Summary

Fields inherited from class org.apache.paimon.flink.action.cdc.SyncDatabaseActionBase

excludingTables, includingTables, mergeShards, mode, tablePrefix, tables, tableSuffix

Fields inherited from class org.apache.paimon.flink.action.cdc.SynchronizationActionBase

caseSensitive, cdcSourceConfig, database, metadataConverters, syncJobHandler, tableConfig, typeMapping

Fields inherited from class org.apache.paimon.flink.action.ActionBase

batchTEnv, catalog, catalogName, catalogOptions, env, flinkCatalog

Constructor Summary

Constructors

Constructor and Description
KafkaSyncDatabaseAction(String warehouse, String database, Map<String,String> catalogConfig, Map<String,String> kafkaConfig)

Method Summary

Methods inherited from class org.apache.paimon.flink.action.cdc.SyncDatabaseActionBase

buildEventParserFactory, buildSink, excludingTables, includingTables, mergeShards, recordParse, validateCaseSensitivity, withMode, withTablePrefix, withTableSuffix

Methods inherited from class org.apache.paimon.flink.action.cdc.SynchronizationActionBase

alterTableOptions, beforeBuildingSourceSink, build, buildSource, run, tableConfig, withMetadataColumns, withTableConfig, withTypeMapping

Methods inherited from class org.apache.paimon.flink.action.ActionBase

catalogConfig, catalogLoader, compatibleCheck, execute, initFlinkCatalog, initFlinkEnv, initPaimonCatalog, toPaimonTypes, withStreamExecutionEnvironment

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KafkaSyncDatabaseAction

public KafkaSyncDatabaseAction(String warehouse,
                               String database,
                               Map<String,String> catalogConfig,
                               Map<String,String> kafkaConfig)