Uses of Class
org.apache.paimon.flink.action.cdc.ComputedColumn

Packages that use ComputedColumn

Package	Description
org.apache.paimon.flink.action.cdc
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.format.json
org.apache.paimon.flink.action.cdc.format.maxwell
org.apache.paimon.flink.action.cdc.format.ogg
org.apache.paimon.flink.action.cdc.mongodb
org.apache.paimon.flink.action.cdc.mongodb.strategy
org.apache.paimon.flink.action.cdc.mysql
org.apache.paimon.flink.action.cdc.postgres

Uses of ComputedColumn in org.apache.paimon.flink.action.cdc

Fields in org.apache.paimon.flink.action.cdc with type parameters of type ComputedColumn

Modifier and Type	Field and Description
protected List<ComputedColumn>	SyncTableActionBase.computedColumns

Methods in org.apache.paimon.flink.action.cdc that return types with arguments of type ComputedColumn

Modifier and Type	Method and Description
static List<ComputedColumn>	ComputedColumnUtils.buildComputedColumns(List<String> computedColumnArgs, List<DataField> physicFields)
static List<ComputedColumn>	ComputedColumnUtils.buildComputedColumns(List<String> computedColumnArgs, List<DataField> physicFields, boolean caseSensitive) The caseSensitive only affects check.

Method parameters in org.apache.paimon.flink.action.cdc with type arguments of type ComputedColumn

Modifier and Type	Method and Description
static Schema	CdcActionCommonUtils.buildPaimonSchema(String tableName, List<String> specifiedPartitionKeys, List<String> specifiedPrimaryKeys, List<ComputedColumn> computedColumns, Map<String,String> tableConfig, Schema sourceSchema, CdcMetadataConverter[] metadataConverters, boolean caseSensitive, boolean strictlyCheckSpecified, boolean requirePrimaryKeys)
org.apache.flink.api.common.functions.FlatMapFunction<CdcSourceRecord,RichCdcMultiplexRecord>	SyncJobHandler.provideRecordParser(List<ComputedColumn> computedColumns, TypeMapping typeMapping, CdcMetadataConverter[] metadataConverters)

Uses of ComputedColumn in org.apache.paimon.flink.action.cdc.format

Fields in org.apache.paimon.flink.action.cdc.format with type parameters of type ComputedColumn

Modifier and Type	Field and Description
protected List<ComputedColumn>	AbstractRecordParser.computedColumns

Method parameters in org.apache.paimon.flink.action.cdc.format with type arguments of type ComputedColumn

Modifier and Type	Method and Description
AbstractRecordParser	AbstractDataFormat.createParser(TypeMapping typeMapping, List<ComputedColumn> computedColumns)
AbstractRecordParser	RecordParserFactory.createParser(TypeMapping typeMapping, List<ComputedColumn> computedColumns) Creates a new instance of AbstractRecordParser with the specified configurations.
AbstractRecordParser	DataFormat.createParser(TypeMapping typeMapping, List<ComputedColumn> computedColumns) Creates a new instance of AbstractRecordParser for this data format with the specified configurations.

Constructor parameters in org.apache.paimon.flink.action.cdc.format with type arguments of type ComputedColumn

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

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

Constructor parameters in org.apache.paimon.flink.action.cdc.format.canal with type arguments of type ComputedColumn

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

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

Constructor parameters in org.apache.paimon.flink.action.cdc.format.debezium with type arguments of type ComputedColumn

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

Uses of ComputedColumn in org.apache.paimon.flink.action.cdc.format.json

Constructor parameters in org.apache.paimon.flink.action.cdc.format.json with type arguments of type ComputedColumn

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

Uses of ComputedColumn in org.apache.paimon.flink.action.cdc.format.maxwell

Constructor parameters in org.apache.paimon.flink.action.cdc.format.maxwell with type arguments of type ComputedColumn

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

Uses of ComputedColumn in org.apache.paimon.flink.action.cdc.format.ogg

Constructor parameters in org.apache.paimon.flink.action.cdc.format.ogg with type arguments of type ComputedColumn

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

Uses of ComputedColumn in org.apache.paimon.flink.action.cdc.mongodb

Constructor parameters in org.apache.paimon.flink.action.cdc.mongodb with type arguments of type ComputedColumn

Constructor and Description
MongoDBRecordParser(List<ComputedColumn> computedColumns, org.apache.flink.configuration.Configuration mongodbConfig)

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

Method parameters in org.apache.paimon.flink.action.cdc.mongodb.strategy with type arguments of type ComputedColumn

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.

Constructor parameters in org.apache.paimon.flink.action.cdc.mongodb.strategy with type arguments of type ComputedColumn

Constructor and Description
Mongo4VersionStrategy(String databaseName, String collection, List<ComputedColumn> computedColumns, org.apache.flink.configuration.Configuration mongodbConfig)

Uses of ComputedColumn in org.apache.paimon.flink.action.cdc.mysql

Constructor parameters in org.apache.paimon.flink.action.cdc.mysql with type arguments of type ComputedColumn

Constructor and Description
MySqlRecordParser(org.apache.flink.configuration.Configuration mySqlConfig, List<ComputedColumn> computedColumns, TypeMapping typeMapping, CdcMetadataConverter[] metadataConverters)

Uses of ComputedColumn in org.apache.paimon.flink.action.cdc.postgres

Constructor parameters in org.apache.paimon.flink.action.cdc.postgres with type arguments of type ComputedColumn

Constructor and Description
PostgresRecordParser(org.apache.flink.configuration.Configuration postgresConfig, List<ComputedColumn> computedColumns, TypeMapping typeMapping, CdcMetadataConverter[] metadataConverters)