org.apache.paimon.flink.action.cdc.mongodb

Class MongoDBActionUtils

java.lang.Object

org.apache.paimon.flink.action.cdc.mongodb.MongoDBActionUtils

public class MongoDBActionUtils
extends Object

Utility class for MongoDB-related actions.

This class provides a set of utility methods to facilitate the creation and configuration of MongoDB sources, as well as the construction of Paimon schemas based on MongoDB schemas. It also includes methods for validating MongoDB configurations and fetching MongoDB version information.

Key functionalities include:

• Building MongoDB sources with various configurations.
• Constructing Paimon schemas based on MongoDB schemas.
• Validating essential MongoDB configurations.

Note: This utility class is designed to be used in conjunction with Flink and Paimon integrations.

Field Summary

Fields

Modifier and Type	Field and Description
static org.apache.flink.configuration.ConfigOption<Boolean>	DEFAULT_ID_GENERATION
static org.apache.flink.configuration.ConfigOption<String>	FIELD_NAME
static org.apache.flink.configuration.ConfigOption<String>	PARSER_PATH
static org.apache.flink.configuration.ConfigOption<String>	START_MODE

Constructor Summary

Constructors

Constructor and Description
MongoDBActionUtils()

Method Summary

Modifier and Type	Method and Description
static org.apache.flink.cdc.connectors.mongodb.source.MongoDBSource<CdcSourceRecord>	buildMongodbSource(org.apache.flink.configuration.Configuration mongodbConfig, String tableList)
static CdcTimestampExtractor	createCdcTimestampExtractor()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

FIELD_NAME

public static final org.apache.flink.configuration.ConfigOption<String> FIELD_NAME

PARSER_PATH

public static final org.apache.flink.configuration.ConfigOption<String> PARSER_PATH

START_MODE

public static final org.apache.flink.configuration.ConfigOption<String> START_MODE

DEFAULT_ID_GENERATION

public static final org.apache.flink.configuration.ConfigOption<Boolean> DEFAULT_ID_GENERATION

Constructor Detail

MongoDBActionUtils

public MongoDBActionUtils()

Method Detail

buildMongodbSource

public static org.apache.flink.cdc.connectors.mongodb.source.MongoDBSource<CdcSourceRecord> buildMongodbSource(org.apache.flink.configuration.Configuration mongodbConfig,
                                                                                                               String tableList)

createCdcTimestampExtractor

public static CdcTimestampExtractor createCdcTimestampExtractor()