public class MongoDBSyncTableAction extends SyncTableActionBase
This action is responsible for:
Usage:
MongoDBSyncTableAction action = new MongoDBSyncTableAction(...); action.run();
SyncTableActionBase.SchemaRetrievalException
computedColumnArgs, computedColumns, fileStoreTable, partitionKeys, primaryKeys, table
caseSensitive, cdcSourceConfig, database, metadataConverters, syncJobHandler, tableConfig, typeMapping
batchTEnv, catalog, catalogName, catalogOptions, env, flinkCatalog
Constructor and Description |
---|
MongoDBSyncTableAction(String warehouse,
String database,
String table,
Map<String,String> catalogConfig,
Map<String,String> mongodbConfig) |
Modifier and Type | Method and Description |
---|---|
protected com.ververica.cdc.connectors.mongodb.source.MongoDBSource<CdcSourceRecord> |
buildSource() |
protected Schema |
retrieveSchema() |
beforeBuildingSourceSink, buildEventParserFactory, buildPaimonSchema, buildSink, fileStoreTable, recordParse, validateCaseSensitivity, withComputedColumnArgs, withPartitionKeys, withPartitionKeys, withPrimaryKeys, withPrimaryKeys
alterTableOptions, build, run, tableConfig, withMetadataColumns, withTableConfig, withTypeMapping
catalogConfig, catalogLoader, compatibleCheck, execute, initFlinkCatalog, initFlinkEnv, initPaimonCatalog, toPaimonTypes, withStreamExecutionEnvironment
protected Schema retrieveSchema()
retrieveSchema
in class SyncTableActionBase
protected com.ververica.cdc.connectors.mongodb.source.MongoDBSource<CdcSourceRecord> buildSource()
buildSource
in class SynchronizationActionBase
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.