public class Mongo4VersionStrategy extends Object implements MongoVersionStrategy
ID_FIELD, OID_FIELD
Constructor and Description |
---|
Mongo4VersionStrategy(String databaseName,
String collection,
List<ComputedColumn> computedColumns,
org.apache.flink.configuration.Configuration mongodbConfig) |
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.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
extractPrimaryKeys, getExtractRow, parseAndTypeJsonRow, parseFieldsFromJsonRecord, processParsedData
public Mongo4VersionStrategy(String databaseName, String collection, List<ComputedColumn> computedColumns, org.apache.flink.configuration.Configuration mongodbConfig)
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
extractRecords
in interface MongoVersionStrategy
root
- The root JsonNode containing the MongoDB record.org.apache.paimon.shade.jackson2.com.fasterxml.jackson.core.JsonProcessingException
- If there's an error during JSON processing.Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.