Uses of Class
org.apache.paimon.flink.sink.cdc.CdcSchema.Builder

Packages that use CdcSchema.Builder

Package	Description
org.apache.paimon.flink.action.cdc.format
org.apache.paimon.flink.action.cdc.format.aliyun
org.apache.paimon.flink.action.cdc.format.canal
org.apache.paimon.flink.action.cdc.format.debezium
org.apache.paimon.flink.action.cdc.mongodb.strategy
org.apache.paimon.flink.sink.cdc

Uses of CdcSchema.Builder in org.apache.paimon.flink.action.cdc.format

Methods in org.apache.paimon.flink.action.cdc.format with parameters of type CdcSchema.Builder

Modifier and Type	Method and Description
protected RichCdcMultiplexRecord	AbstractRecordParser.createRecord(RowKind rowKind, Map<String,String> data, CdcSchema.Builder schemaBuilder) Handle case sensitivity here.
protected void	AbstractRecordParser.evalComputedColumns(Map<String,String> rowData, CdcSchema.Builder schemaBuilder) generate values for computed columns.
protected Map<String,String>	AbstractJsonRecordParser.extractRowData(org.apache.paimon.shade.jackson2.com.fasterxml.jackson.databind.JsonNode record, CdcSchema.Builder schemaBuilder)
protected void	AbstractJsonRecordParser.fillDefaultTypes(org.apache.paimon.shade.jackson2.com.fasterxml.jackson.databind.JsonNode record, CdcSchema.Builder schemaBuilder)

Uses of CdcSchema.Builder in org.apache.paimon.flink.action.cdc.format.aliyun

Methods in org.apache.paimon.flink.action.cdc.format.aliyun with parameters of type CdcSchema.Builder

Modifier and Type	Method and Description
protected Map<String,String>	AliyunRecordParser.extractRowData(org.apache.paimon.shade.jackson2.com.fasterxml.jackson.databind.JsonNode record, CdcSchema.Builder schemaBuilder)

Uses of CdcSchema.Builder in org.apache.paimon.flink.action.cdc.format.canal

Methods in org.apache.paimon.flink.action.cdc.format.canal with parameters of type CdcSchema.Builder

Modifier and Type	Method and Description
protected Map<String,String>	CanalRecordParser.extractRowData(org.apache.paimon.shade.jackson2.com.fasterxml.jackson.databind.JsonNode record, CdcSchema.Builder schemaBuilder)

Uses of CdcSchema.Builder in org.apache.paimon.flink.action.cdc.format.debezium

Methods in org.apache.paimon.flink.action.cdc.format.debezium with parameters of type CdcSchema.Builder

Modifier and Type	Method and Description
protected Map<String,String>	DebeziumBsonRecordParser.extractRowData(org.apache.paimon.shade.jackson2.com.fasterxml.jackson.databind.JsonNode record, CdcSchema.Builder schemaBuilder)
protected Map<String,String>	DebeziumJsonRecordParser.extractRowData(org.apache.paimon.shade.jackson2.com.fasterxml.jackson.databind.JsonNode record, CdcSchema.Builder schemaBuilder)

Uses of CdcSchema.Builder in org.apache.paimon.flink.action.cdc.mongodb.strategy

Methods in org.apache.paimon.flink.action.cdc.mongodb.strategy with parameters of type CdcSchema.Builder

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

Uses of CdcSchema.Builder in org.apache.paimon.flink.sink.cdc

Methods in org.apache.paimon.flink.sink.cdc that return CdcSchema.Builder

Modifier and Type	Method and Description
CdcSchema.Builder	CdcSchema.Builder.column(DataField dataField) Declares a column that is appended to this schema.
CdcSchema.Builder	CdcSchema.Builder.column(String columnName, DataType dataType) Declares a column that is appended to this schema.
CdcSchema.Builder	CdcSchema.Builder.column(String columnName, DataType dataType, String description) Declares a column that is appended to this schema.
CdcSchema.Builder	CdcSchema.Builder.comment(String comment) Declares table comment.
static CdcSchema.Builder	CdcSchema.newBuilder() Builder for configuring and creating instances of CdcSchema.
CdcSchema.Builder	CdcSchema.Builder.primaryKey(List<String> columnNames) Declares a primary key constraint for a set of given columns.
CdcSchema.Builder	CdcSchema.Builder.primaryKey(String... columnNames) Declares a primary key constraint for a set of given columns.