org.apache.paimon.flink.action.cdc.format.json

Class JsonRecordParser

java.lang.Object

org.apache.paimon.flink.action.cdc.format.AbstractRecordParser

org.apache.paimon.flink.action.cdc.format.AbstractJsonRecordParser

org.apache.paimon.flink.action.cdc.format.json.JsonRecordParser

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.functions.FlatMapFunction<CdcSourceRecord,RichCdcMultiplexRecord>, org.apache.flink.api.common.functions.Function

public class JsonRecordParser
extends AbstractJsonRecordParser

The JsonRecordParser class extends the abstract AbstractJsonRecordParser class and is designed to parse JSON records.

This class treats JSON records as special CDC data with only insert operation type and generates RichCdcMultiplexRecord objects with only INSERT operation types.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.paimon.flink.action.cdc.format.AbstractJsonRecordParser

root

Fields inherited from class org.apache.paimon.flink.action.cdc.format.AbstractRecordParser

computedColumns, FIELD_DATABASE, FIELD_TABLE, typeMapping

Constructor Summary

Constructors

Constructor and Description
JsonRecordParser(TypeMapping typeMapping, List<ComputedColumn> computedColumns)

Method Summary

Modifier and Type	Method and Description
protected String	dataField()
protected List<RichCdcMultiplexRecord>	extractRecords()
protected String	format()
protected String	primaryField()

Methods inherited from class org.apache.paimon.flink.action.cdc.format.AbstractJsonRecordParser

checkNotNull, checkNotNull, extractPrimaryKeys, extractRowData, fillDefaultTypes, getAndCheck, getAndCheck, getDatabaseName, getTableName, mergeOldRecord, processRecord, setRoot

Methods inherited from class org.apache.paimon.flink.action.cdc.format.AbstractRecordParser

buildSchema, createRecord, evalComputedColumns, flatMap, isDDL

Methods inherited from class java.lang.Object

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

Constructor Detail

JsonRecordParser

public JsonRecordParser(TypeMapping typeMapping,
                        List<ComputedColumn> computedColumns)

Method Detail

extractRecords

protected List<RichCdcMultiplexRecord> extractRecords()

Specified by:

extractRecords in class AbstractRecordParser

primaryField

protected String primaryField()

Specified by:

primaryField in class AbstractJsonRecordParser

dataField

protected String dataField()

Specified by:

dataField in class AbstractJsonRecordParser

format

protected String format()

Specified by:

format in class AbstractRecordParser