public class MongoDBSyncDatabaseAction extends SyncDatabaseActionBase
This class provides functionality to read data from a MongoDB source, process it, and then synchronize it with a target system. It supports various configurations, including table prefixes, suffixes, and inclusion/exclusion patterns.
Key features include:
Note: This action is primarily intended for use in Flink streaming applications that synchronize MongoDB data with other systems.
excludingTables, includingTables, mergeShards, mode, tablePrefix, tables, tableSuffix
caseSensitive, cdcSourceConfig, database, metadataConverters, syncJobHandler, tableConfig, typeMapping
batchTEnv, catalog, catalogName, catalogOptions, env, flinkCatalog
Constructor and Description |
---|
MongoDBSyncDatabaseAction(String warehouse,
String database,
Map<String,String> catalogConfig,
Map<String,String> mongodbConfig) |
Modifier and Type | Method and Description |
---|---|
protected com.ververica.cdc.connectors.mongodb.source.MongoDBSource<CdcSourceRecord> |
buildSource() |
buildEventParserFactory, buildSink, excludingTables, includingTables, mergeShards, recordParse, validateCaseSensitivity, withMode, withTablePrefix, withTableSuffix
alterTableOptions, beforeBuildingSourceSink, build, run, tableConfig, withMetadataColumns, withTableConfig, withTypeMapping
catalogConfig, catalogLoader, compatibleCheck, execute, initFlinkCatalog, initFlinkEnv, initPaimonCatalog, toPaimonTypes, withStreamExecutionEnvironment
protected com.ververica.cdc.connectors.mongodb.source.MongoDBSource<CdcSourceRecord> buildSource()
buildSource
in class SynchronizationActionBase
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.