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

computedColumns, dbPrefix, dbSuffix, eagerInit, excludingDbs, excludingTables, includingDbs, includingTables, mergeShards, mode, partitionKeyMultiple, partitionKeys, primaryKeys, tableMapping, 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 database, Map<String,String> catalogConfig, Map<String,String> kafkaConfig)

Method Summary

Modifier and Type	Method and Description
protected CdcTimestampExtractor	createCdcTimestampExtractor()
protected boolean	requirePrimaryKeys()

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

buildEventParserFactory, buildSink, eagerInit, excludingDbs, excludingTables, includingDbs, includingTables, mergeShards, recordParse, withComputedColumnArgs, withDbPrefix, withDbSuffix, withMode, withPartitionKeyMultiple, withPartitionKeys, withPrimaryKeys, withTableMapping, withTablePrefix, withTableSuffix

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

alterTableOptions, beforeBuildingSourceSink, build, buildSource, run, tableConfig, validateRuntimeExecutionMode, 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 database,
                               Map<String,String> catalogConfig,
                               Map<String,String> kafkaConfig)

Method Detail

createCdcTimestampExtractor

protected CdcTimestampExtractor createCdcTimestampExtractor()

Overrides:

createCdcTimestampExtractor in class SynchronizationActionBase

requirePrimaryKeys

protected boolean requirePrimaryKeys()

Specified by:

requirePrimaryKeys in class SyncDatabaseActionBase