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

Class PulsarSyncTableAction

java.lang.Object

org.apache.paimon.flink.action.ActionBase

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

org.apache.paimon.flink.action.cdc.SyncTableActionBase

org.apache.paimon.flink.action.cdc.MessageQueueSyncTableActionBase

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

All Implemented Interfaces:

Action

public class PulsarSyncTableAction
extends MessageQueueSyncTableActionBase

Synchronize table from Pulsar.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.paimon.flink.action.cdc.SyncTableActionBase

SyncTableActionBase.SchemaRetrievalException

Field Summary

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

computedColumnArgs, computedColumns, fileStoreTable, partitionKeys, primaryKeys, table

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

Method Summary

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

buildPaimonSchema, createCdcTimestampExtractor, retrieveSchema

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

beforeBuildingSourceSink, buildEventParserFactory, buildSink, fileStoreTable, recordParse, validateCaseSensitivity, withComputedColumnArgs, withPartitionKeys, withPartitionKeys, withPrimaryKeys, withPrimaryKeys

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

alterTableOptions, 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

PulsarSyncTableAction

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