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

Class MongodbSchemaUtils

java.lang.Object

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

public class MongodbSchemaUtils
extends Object

Build schema from a MongoDB collection.

The schema can be acquired in two modes: SPECIFIED and DYNAMIC. In the SPECIFIED mode, the schema details are provided explicitly, while in the DYNAMIC mode, the schema is inferred from the first document in the collection.

Constructor Summary

Constructors

Constructor and Description
MongodbSchemaUtils()

Method Summary

Modifier and Type	Method and Description
static Schema	getMongodbSchema(org.apache.flink.configuration.Configuration mongodbConfig) The schema can be created in one of the two modes: SPECIFIED: In this mode, the schema is created based on the explicit column names provided in the configuration.

Methods inherited from class java.lang.Object

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

Constructor Detail

MongodbSchemaUtils

public MongodbSchemaUtils()

Method Detail

getMongodbSchema

public static Schema getMongodbSchema(org.apache.flink.configuration.Configuration mongodbConfig)

The schema can be created in one of the two modes:

• SPECIFIED: In this mode, the schema is created based on the explicit column names provided in the configuration. The data types for all columns are assumed to be STRING.
• DYNAMIC: In this mode, the schema is inferred dynamically from the first document in the specified MongoDB collection.

The Configuration object passed to the createSchema method should have the necessary MongoDB configuration properties set, including the host address, database name, collection name, and optionally, the username and password for authentication. For the SPECIFIED mode, the field names should also be specified in the configuration.