public class DebeziumSchemaUtils extends Object
Modifier and Type | Field and Description |
---|---|
protected static String |
CONNECT_NAME_PROP |
protected static String |
CONNECT_PARAMETERS_PROP |
static String |
FIELD_AFTER |
static String |
FIELD_BEFORE |
static String |
FIELD_DB |
static String |
FIELD_PAYLOAD |
static String |
FIELD_PRIMARY |
static String |
FIELD_SCHEMA |
static String |
FIELD_SOURCE |
static String |
FIELD_TYPE |
static String |
OP_DELETE |
static String |
OP_INSERT |
static String |
OP_MESSAGE |
static String |
OP_READE |
static String |
OP_TRUNCATE |
static String |
OP_UPDATE |
Constructor and Description |
---|
DebeziumSchemaUtils() |
Modifier and Type | Method and Description |
---|---|
static DataType |
avroToPaimonDataType(org.apache.avro.Schema schema) |
static String |
decimalLogicalName()
get decimal logical name.
|
static Map<String,String> |
getAvroConnectParameters(org.apache.avro.Schema schema) |
static DataType |
toDataType(String debeziumType,
String className,
Map<String,String> parameters) |
static String |
transformAvroRawValue(String rawValue,
String debeziumType,
String className,
TypeMapping typeMapping,
Object origin,
java.time.ZoneId serverTimeZone) |
static String |
transformRawValue(String rawValue,
String debeziumType,
String className,
TypeMapping typeMapping,
org.apache.paimon.shade.jackson2.com.fasterxml.jackson.databind.JsonNode origin,
java.time.ZoneId serverTimeZone) |
static String |
transformRawValue(String rawValue,
String debeziumType,
String className,
TypeMapping typeMapping,
java.util.function.Supplier<ByteBuffer> geometryGetter,
java.time.ZoneId serverTimeZone)
Transform raw string value according to schema.
|
public static final String FIELD_SCHEMA
public static final String FIELD_PAYLOAD
public static final String FIELD_SOURCE
public static final String FIELD_PRIMARY
public static final String FIELD_DB
public static final String FIELD_BEFORE
public static final String FIELD_AFTER
public static final String FIELD_TYPE
public static final String OP_READE
public static final String OP_INSERT
public static final String OP_UPDATE
public static final String OP_DELETE
public static final String OP_TRUNCATE
public static final String OP_MESSAGE
protected static final String CONNECT_PARAMETERS_PROP
protected static final String CONNECT_NAME_PROP
public static String transformRawValue(@Nullable String rawValue, String debeziumType, @Nullable String className, TypeMapping typeMapping, org.apache.paimon.shade.jackson2.com.fasterxml.jackson.databind.JsonNode origin, java.time.ZoneId serverTimeZone)
public static String transformAvroRawValue(@Nullable String rawValue, String debeziumType, @Nullable String className, TypeMapping typeMapping, Object origin, java.time.ZoneId serverTimeZone)
public static String transformRawValue(@Nullable String rawValue, String debeziumType, @Nullable String className, TypeMapping typeMapping, java.util.function.Supplier<ByteBuffer> geometryGetter, java.time.ZoneId serverTimeZone)
public static DataType toDataType(String debeziumType, @Nullable String className, Map<String,String> parameters)
public static String decimalLogicalName()
Using the maven shade plugin will shade the constant value. see ... so the string org.apache.kafka.connect.data.Decimal is shaded to org.apache.flink.kafka.shaded .org.apache.kafka.connect.data.Decimal.
public static Map<String,String> getAvroConnectParameters(org.apache.avro.Schema schema)
public static DataType avroToPaimonDataType(org.apache.avro.Schema schema)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.