public class CdcActionCommonUtils extends Object
Modifier and Type | Field and Description |
---|---|
static String |
COMPUTED_COLUMN |
static String |
EXCLUDING_TABLES |
static String |
INCLUDING_TABLES |
static String |
KAFKA_CONF |
static String |
METADATA_COLUMN |
static String |
MONGODB_CONF |
static String |
MULTIPLE_TABLE_PARTITION_KEYS |
static String |
MYSQL_CONF |
static String |
PARTITION_KEYS |
static String |
POSTGRES_CONF |
static String |
PRIMARY_KEYS |
static String |
PULSAR_CONF |
static String |
TABLE_PREFIX |
static String |
TABLE_SUFFIX |
static String |
TYPE_MAPPING |
Constructor and Description |
---|
CdcActionCommonUtils() |
Modifier and Type | Method and Description |
---|---|
static void |
assertSchemaCompatible(TableSchema paimonSchema,
List<DataField> sourceTableFields) |
static Schema |
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) |
static void |
checkDuplicateFields(String tableName,
List<String> fieldNames) |
static void |
checkOneRequiredOption(org.apache.flink.configuration.Configuration config,
String confName,
org.apache.flink.configuration.ConfigOption<?>... configOptions) |
static void |
checkRequiredOptions(org.apache.flink.configuration.Configuration config,
String confName,
org.apache.flink.configuration.ConfigOption<?>... configOptions) |
static String |
combinedModeTableList(String databasePattern,
String includingTablePattern,
List<Identifier> excludedTables) |
static List<String> |
listCaseConvert(List<String> origin,
boolean caseSensitive) |
static boolean |
schemaCompatible(TableSchema paimonSchema,
List<DataField> sourceTableFields) |
static String |
tableList(MultiTablesSinkMode mode,
String databasePattern,
String includingTablePattern,
List<Identifier> monitoredTables,
List<Identifier> excludedTables) |
public static final String KAFKA_CONF
public static final String MONGODB_CONF
public static final String MYSQL_CONF
public static final String POSTGRES_CONF
public static final String PULSAR_CONF
public static final String TABLE_PREFIX
public static final String TABLE_SUFFIX
public static final String INCLUDING_TABLES
public static final String EXCLUDING_TABLES
public static final String TYPE_MAPPING
public static final String PARTITION_KEYS
public static final String PRIMARY_KEYS
public static final String COMPUTED_COLUMN
public static final String METADATA_COLUMN
public static final String MULTIPLE_TABLE_PARTITION_KEYS
public static void assertSchemaCompatible(TableSchema paimonSchema, List<DataField> sourceTableFields)
public static boolean schemaCompatible(TableSchema paimonSchema, List<DataField> sourceTableFields)
public static List<String> listCaseConvert(List<String> origin, boolean caseSensitive)
public static Schema 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)
public static void checkDuplicateFields(String tableName, List<String> fieldNames)
public static String tableList(MultiTablesSinkMode mode, String databasePattern, String includingTablePattern, List<Identifier> monitoredTables, List<Identifier> excludedTables)
public static String combinedModeTableList(String databasePattern, String includingTablePattern, List<Identifier> excludedTables)
public static void checkRequiredOptions(org.apache.flink.configuration.Configuration config, String confName, org.apache.flink.configuration.ConfigOption<?>... configOptions)
public static void checkOneRequiredOption(org.apache.flink.configuration.Configuration config, String confName, org.apache.flink.configuration.ConfigOption<?>... configOptions)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.