Uses of Class
org.apache.paimon.types.RowType.Builder

Packages that use RowType.Builder

Package	Description
org.apache.paimon.flink.action.cdc.format
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.types

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

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

Modifier and Type	Method and Description
protected void	AbstractRecordParser.evalComputedColumns(Map<String,String> rowData, RowType.Builder rowTypeBuilder) generate values for computed columns.
protected Map<String,String>	AbstractJsonRecordParser.extractRowData(org.apache.paimon.shade.jackson2.com.fasterxml.jackson.databind.JsonNode record, RowType.Builder rowTypeBuilder)
protected void	AbstractJsonRecordParser.fillDefaultTypes(org.apache.paimon.shade.jackson2.com.fasterxml.jackson.databind.JsonNode record, RowType.Builder rowTypeBuilder)

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

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

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

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

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

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

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

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

Modifier and Type	Method and Description
default Map<String,String>	MongoVersionStrategy.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>	MongoVersionStrategy.parseAndTypeJsonRow(String evaluate, RowType.Builder rowTypeBuilder, 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, RowType.Builder rowTypeBuilder) Parses fields from a JSON record based on the given parameters.
static Map<String,String>	MongoVersionStrategy.processParsedData(Map<String,String> parsedRow, RowType.Builder rowTypeBuilder, List<ComputedColumn> computedColumns) Processes the parsed data to generate the result map and update field types.

Uses of RowType.Builder in org.apache.paimon.types

Methods in org.apache.paimon.types that return RowType.Builder

Modifier and Type	Method and Description
static RowType.Builder	RowType.builder()
static RowType.Builder	RowType.builder(boolean isNullable, AtomicInteger fieldId)
RowType.Builder	RowType.Builder.field(String name, DataType type)
RowType.Builder	RowType.Builder.field(String name, DataType type, String description)
RowType.Builder	RowType.Builder.fields(DataType... types)
RowType.Builder	RowType.Builder.fields(DataType[] types, String[] names)
RowType.Builder	RowType.Builder.fields(List<DataType> types)