public class MongoDBActionUtils extends Object
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:
Note: This utility class is designed to be used in conjunction with Flink and Paimon integrations.
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 and Description |
---|
MongoDBActionUtils() |
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() |
public static final org.apache.flink.configuration.ConfigOption<String> FIELD_NAME
public static final org.apache.flink.configuration.ConfigOption<String> PARSER_PATH
public static final org.apache.flink.configuration.ConfigOption<String> START_MODE
public static final org.apache.flink.configuration.ConfigOption<Boolean> DEFAULT_ID_GENERATION
public static org.apache.flink.cdc.connectors.mongodb.source.MongoDBSource<CdcSourceRecord> buildMongodbSource(org.apache.flink.configuration.Configuration mongodbConfig, String tableList)
public static CdcTimestampExtractor createCdcTimestampExtractor()
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.