Modifier and Type | Field and Description |
---|---|
protected List<ComputedColumn> |
SyncTableActionBase.computedColumns |
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.
|
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) |
Modifier and Type | Field and Description |
---|---|
protected List<ComputedColumn> |
AbstractRecordParser.computedColumns |
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 and Description |
---|
AbstractJsonRecordParser(TypeMapping typeMapping,
List<ComputedColumn> computedColumns) |
AbstractRecordParser(TypeMapping typeMapping,
List<ComputedColumn> computedColumns) |
Constructor and Description |
---|
AliyunRecordParser(TypeMapping typeMapping,
List<ComputedColumn> computedColumns) |
Constructor and Description |
---|
CanalRecordParser(TypeMapping typeMapping,
List<ComputedColumn> computedColumns) |
Constructor and Description |
---|
DebeziumAvroRecordParser(TypeMapping typeMapping,
List<ComputedColumn> computedColumns) |
DebeziumJsonRecordParser(TypeMapping typeMapping,
List<ComputedColumn> computedColumns) |
Constructor and Description |
---|
DMSRecordParser(TypeMapping typeMapping,
List<ComputedColumn> computedColumns) |
Constructor and Description |
---|
JsonRecordParser(TypeMapping typeMapping,
List<ComputedColumn> computedColumns) |
Constructor and Description |
---|
MaxwellRecordParser(TypeMapping typeMapping,
List<ComputedColumn> computedColumns) |
Constructor and Description |
---|
OggRecordParser(TypeMapping typeMapping,
List<ComputedColumn> computedColumns) |
Constructor and Description |
---|
MongoDBRecordParser(List<ComputedColumn> computedColumns,
org.apache.flink.configuration.Configuration mongodbConfig) |
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 and Description |
---|
Mongo4VersionStrategy(String databaseName,
String collection,
List<ComputedColumn> computedColumns,
org.apache.flink.configuration.Configuration mongodbConfig) |
Constructor and Description |
---|
MySqlRecordParser(org.apache.flink.configuration.Configuration mySqlConfig,
List<ComputedColumn> computedColumns,
TypeMapping typeMapping,
CdcMetadataConverter[] metadataConverters) |
Constructor and Description |
---|
PostgresRecordParser(org.apache.flink.configuration.Configuration postgresConfig,
List<ComputedColumn> computedColumns,
TypeMapping typeMapping,
CdcMetadataConverter[] metadataConverters) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.