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

Class Mongo4VersionStrategy

java.lang.Object

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

All Implemented Interfaces:

MongoVersionStrategy

public class Mongo4VersionStrategy
extends Object
implements MongoVersionStrategy

Implementation class for extracting records from MongoDB versions greater than 4.x and less than 6.x.

Field Summary

Fields inherited from interface org.apache.paimon.flink.action.cdc.mongodb.strategy.MongoVersionStrategy

ID_FIELD, OID_FIELD

Constructor Summary

Constructors

Constructor and Description
Mongo4VersionStrategy(String databaseName, String collection, List<ComputedColumn> computedColumns, org.apache.flink.configuration.Configuration mongodbConfig)

Method Summary

Modifier and Type	Method and Description
List<RichCdcMultiplexRecord>	extractRecords(org.apache.paimon.shade.jackson2.com.fasterxml.jackson.databind.JsonNode root) Extracts records from the provided JsonNode based on the MongoDB version strategy.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.paimon.flink.action.cdc.mongodb.strategy.MongoVersionStrategy

extractPrimaryKeys, getExtractRow, parseAndTypeJsonRow, parseFieldsFromJsonRecord, processParsedData

Constructor Detail

Mongo4VersionStrategy

public Mongo4VersionStrategy(String databaseName,
                             String collection,
                             List<ComputedColumn> computedColumns,
                             org.apache.flink.configuration.Configuration mongodbConfig)

Method Detail

extractRecords

public List<RichCdcMultiplexRecord> extractRecords(org.apache.paimon.shade.jackson2.com.fasterxml.jackson.databind.JsonNode root)
                                            throws org.apache.paimon.shade.jackson2.com.fasterxml.jackson.core.JsonProcessingException

Extracts records from the provided JsonNode based on the MongoDB version strategy.

Specified by:

extractRecords in interface MongoVersionStrategy

Parameters:

root - The root JsonNode containing the MongoDB record.

Returns:

A list of RichCdcMultiplexRecord extracted from the root node.

Throws:

org.apache.paimon.shade.jackson2.com.fasterxml.jackson.core.JsonProcessingException - If there's an error during JSON processing.