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
allowUpperCase, 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 org.apache.flink.cdc.connectors.mongodb.source.MongoDBSource<CdcSourceRecord> |
buildSource() |
protected CdcTimestampExtractor |
createCdcTimestampExtractor() |
protected Schema |
retrieveSchema() |
beforeBuildingSourceSink, buildEventParserFactory, buildPaimonSchema, buildSink, fileStoreTable, recordParse, validateCaseSensitivity, withComputedColumnArgs, withPartitionKeys, withPartitionKeys, withPrimaryKeys, withPrimaryKeys
alterTableOptions, build, run, tableConfig, validateRuntimeExecutionMode, withMetadataColumns, withTableConfig, withTypeMapping
catalogConfig, catalogLoader, compatibleCheck, execute, initFlinkCatalog, initFlinkEnv, initPaimonCatalog, toPaimonTypes, withStreamExecutionEnvironment
protected Schema retrieveSchema()
retrieveSchema
in class SyncTableActionBase
protected CdcTimestampExtractor createCdcTimestampExtractor()
createCdcTimestampExtractor
in class SynchronizationActionBase
protected org.apache.flink.cdc.connectors.mongodb.source.MongoDBSource<CdcSourceRecord> buildSource()
buildSource
in class SynchronizationActionBase
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.