public class PulsarSyncTableAction extends MessageQueueSyncTableActionBase
SyncTableActionBase.SchemaRetrievalException
computedColumnArgs, computedColumns, fileStoreTable, partitionKeys, primaryKeys, table
allowUpperCase, cdcSourceConfig, database, metadataConverters, syncJobHandler, tableConfig, typeMapping
batchTEnv, catalog, catalogName, catalogOptions, env, flinkCatalog
Constructor and Description |
---|
PulsarSyncTableAction(String warehouse,
String database,
String table,
Map<String,String> catalogConfig,
Map<String,String> pulsarConfig) |
buildPaimonSchema, createCdcTimestampExtractor, retrieveSchema
beforeBuildingSourceSink, buildEventParserFactory, buildSink, fileStoreTable, recordParse, validateCaseSensitivity, withComputedColumnArgs, withPartitionKeys, withPartitionKeys, withPrimaryKeys, withPrimaryKeys
alterTableOptions, build, buildSource, run, tableConfig, validateRuntimeExecutionMode, withMetadataColumns, withTableConfig, withTypeMapping
catalogConfig, catalogLoader, compatibleCheck, execute, initFlinkCatalog, initFlinkEnv, initPaimonCatalog, toPaimonTypes, withStreamExecutionEnvironment
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.