org.apache.paimon.flink.action.cdc.pulsar

Class PulsarSyncDatabaseAction

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.pulsar.PulsarSyncDatabaseAction

All Implemented Interfaces:

Action

public class PulsarSyncDatabaseAction
extends SyncDatabaseActionBase

Synchronize database from Pulsar.

Field Summary

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

excludingTables, includingTables, mergeShards, mode, partitionKeyMultiple, partitionKeys, primaryKeys, tablePrefix, tables, tableSuffix

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

allowUpperCase, 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
PulsarSyncDatabaseAction(String warehouse, String database, Map<String,String> catalogConfig, Map<String,String> pulsarConfig)

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, excludingTables, includingTables, mergeShards, recordParse, validateCaseSensitivity, withMode, withPartitionKeyMultiple, withPartitionKeys, withPrimaryKeys, 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

PulsarSyncDatabaseAction

public PulsarSyncDatabaseAction(String warehouse,
                                String database,
                                Map<String,String> catalogConfig,
                                Map<String,String> pulsarConfig)

Method Detail

createCdcTimestampExtractor

protected CdcTimestampExtractor createCdcTimestampExtractor()

Overrides:

createCdcTimestampExtractor in class SynchronizationActionBase

requirePrimaryKeys

protected boolean requirePrimaryKeys()

Specified by:

requirePrimaryKeys in class SyncDatabaseActionBase