Uses of Interface
org.apache.paimon.flink.action.cdc.CdcMetadataConverter

Packages that use CdcMetadataConverter

Package	Description
org.apache.paimon.flink.action.cdc
org.apache.paimon.flink.action.cdc.mysql
org.apache.paimon.flink.action.cdc.postgres
org.apache.paimon.flink.sink.cdc

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

Classes in org.apache.paimon.flink.action.cdc that implement CdcMetadataConverter

Modifier and Type	Class and Description
static class	CdcMetadataConverter.DatabaseNameConverter Name of the database that contain the row.
static class	CdcMetadataConverter.OpTsConverter It indicates the time that the change was made in the database.
static class	CdcMetadataConverter.SchemaNameConverter Name of the schema that contain the row.
static class	CdcMetadataConverter.TableNameConverter Name of the table that contain the row.

Fields in org.apache.paimon.flink.action.cdc declared as CdcMetadataConverter

Modifier and Type	Field and Description
protected CdcMetadataConverter[]	SynchronizationActionBase.metadataConverters

Methods in org.apache.paimon.flink.action.cdc that return CdcMetadataConverter

Modifier and Type	Method and Description
static CdcMetadataConverter	CdcMetadataProcessor.converter(SyncJobHandler.SourceType sourceType, String column)
CdcMetadataConverter	SyncJobHandler.provideMetadataConverter(String column)

Methods in org.apache.paimon.flink.action.cdc with parameters of type CdcMetadataConverter

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 CdcMetadataConverter in org.apache.paimon.flink.action.cdc.mysql

Constructors in org.apache.paimon.flink.action.cdc.mysql with parameters of type CdcMetadataConverter

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

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

Constructors in org.apache.paimon.flink.action.cdc.postgres with parameters of type CdcMetadataConverter

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

Uses of CdcMetadataConverter in org.apache.paimon.flink.sink.cdc

Constructors in org.apache.paimon.flink.sink.cdc with parameters of type CdcMetadataConverter

Constructor and Description
NewTableSchemaBuilder(Map<String,String> tableConfig, boolean caseSensitive, List<String> partitionKeys, List<String> primaryKeys, boolean requirePrimaryKeys, Map<String,List<String>> partitionKeyMultiple, CdcMetadataConverter[] metadataConverters)