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

Interface MongoVersionStrategy

All Known Implementing Classes:

Mongo4VersionStrategy

public interface MongoVersionStrategy

Interface for processing strategies tailored for different MongoDB versions.

Field Summary

Fields

Modifier and Type	Field and Description
static String	ID_FIELD
static String	OID_FIELD

Method Summary

Modifier and Type	Method and Description
default List<String>	extractPrimaryKeys() Extracts primary keys from the MongoDB record.
List<RichCdcMultiplexRecord>	extractRecords(org.apache.paimon.shade.jackson2.com.fasterxml.jackson.databind.JsonNode root) Extracts records from the provided JsonNode.
default Map<String,String>	getExtractRow(org.apache.paimon.shade.jackson2.com.fasterxml.jackson.databind.JsonNode jsonNode, RowType.Builder rowTypeBuilder, List<ComputedColumn> computedColumns, org.apache.flink.configuration.Configuration mongodbConfig) Determines the extraction mode and retrieves the row accordingly.
default Map<String,String>	parseAndTypeJsonRow(String evaluate, RowType.Builder rowTypeBuilder, List<ComputedColumn> computedColumns) Parses and types a JSON row based on the given parameters.
static Map<String,String>	parseFieldsFromJsonRecord(String record, String fieldPaths, String fieldNames, List<ComputedColumn> computedColumns, RowType.Builder rowTypeBuilder) Parses fields from a JSON record based on the given parameters.
static Map<String,String>	processParsedData(Map<String,String> parsedRow, RowType.Builder rowTypeBuilder, List<ComputedColumn> computedColumns) Processes the parsed data to generate the result map and update field types.

Field Detail

ID_FIELD

static final String ID_FIELD

See Also:

Constant Field Values

OID_FIELD

static final String OID_FIELD

See Also:

Constant Field Values

Method Detail

extractRecords

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.

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.

extractPrimaryKeys

default List<String> extractPrimaryKeys()

Extracts primary keys from the MongoDB record.

Returns:

A list of primary keys.

getExtractRow

default Map<String,String> getExtractRow(org.apache.paimon.shade.jackson2.com.fasterxml.jackson.databind.JsonNode jsonNode,
                                         RowType.Builder rowTypeBuilder,
                                         List<ComputedColumn> computedColumns,
                                         org.apache.flink.configuration.Configuration mongodbConfig)
                                  throws org.apache.paimon.shade.jackson2.com.fasterxml.jackson.core.JsonProcessingException

Determines the extraction mode and retrieves the row accordingly.

Parameters:

jsonNode - The JsonNode representing the MongoDB document.

rowTypeBuilder - row type builder.

mongodbConfig - Configuration for the MongoDB connection.

Returns:

A map representing the extracted row.

Throws:

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

parseAndTypeJsonRow

default Map<String,String> parseAndTypeJsonRow(String evaluate,
                                               RowType.Builder rowTypeBuilder,
                                               List<ComputedColumn> computedColumns)

Parses and types a JSON row based on the given parameters.

parseFieldsFromJsonRecord

static Map<String,String> parseFieldsFromJsonRecord(String record,
                                                    String fieldPaths,
                                                    String fieldNames,
                                                    List<ComputedColumn> computedColumns,
                                                    RowType.Builder rowTypeBuilder)

Parses fields from a JSON record based on the given parameters.

processParsedData

static Map<String,String> processParsedData(Map<String,String> parsedRow,
                                            RowType.Builder rowTypeBuilder,
                                            List<ComputedColumn> computedColumns)

Processes the parsed data to generate the result map and update field types.