org.apache.flink.cdc.connectors.oceanbase.sink

类 OceanBaseUtils

java.lang.Object

org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils

public class OceanBaseUtils
extends Object

Utilities for conversion from source table to OceanBase table.

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	OceanBaseUtils.CdcDataTypeTransformer Transforms CDC DataType to OceanBase data type.

字段概要

字段

限定符和类型	字段和说明
static String	BIGINT
static String	BINARY
static String	BOOLEAN
static String	CHAR
static String	DATE
static String	DATETIME
static String	DECIMAL
static String	DOUBLE
static String	FLOAT
static String	INT
static String	JSON
static String	LONGBLOB
static int	MAX_CHAR_SIZE Max size of char type of OceanBase.
static int	MAX_VARBINARY_SIZE The max VARBINARY column length is 1048576.
static int	MAX_VARCHAR_SIZE Max size of varchar type of OceanBase.
static String	SMALLINT
static String	STRING
static String	TEXT
static String	TIME
static String	TIMESTAMP
static String	TINYINT
static String	VARBINARY
static String	VARCHAR

构造器概要

构造器

构造器和说明
OceanBaseUtils()

方法概要

限定符和类型	方法和说明
static void	toOceanBaseDataType(org.apache.flink.cdc.common.schema.Column cdcColumn, boolean isPrimaryKeys, OceanBaseColumn.Builder builder) Convert CDC data type to OceanBase data type.
static OceanBaseTable	toOceanBaseTable(org.apache.flink.cdc.common.event.TableId tableId, org.apache.flink.cdc.common.schema.Schema schema) Convert a source table to OceanBaseTable.

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

BOOLEAN

public static final String BOOLEAN

另请参阅:

常量字段值

TINYINT

public static final String TINYINT

另请参阅:

常量字段值

SMALLINT

public static final String SMALLINT

另请参阅:

常量字段值

INT

public static final String INT

另请参阅:

常量字段值

BIGINT

public static final String BIGINT

另请参阅:

常量字段值

BINARY

public static final String BINARY

另请参阅:

常量字段值

VARBINARY

public static final String VARBINARY

另请参阅:

常量字段值

FLOAT

public static final String FLOAT

另请参阅:

常量字段值

DOUBLE

public static final String DOUBLE

另请参阅:

常量字段值

DECIMAL

public static final String DECIMAL

另请参阅:

常量字段值

CHAR

public static final String CHAR

另请参阅:

常量字段值

VARCHAR

public static final String VARCHAR

另请参阅:

常量字段值

STRING

public static final String STRING

另请参阅:

常量字段值

DATE

public static final String DATE

另请参阅:

常量字段值

DATETIME

public static final String DATETIME

另请参阅:

常量字段值

TIMESTAMP

public static final String TIMESTAMP

另请参阅:

常量字段值

TIME

public static final String TIME

另请参阅:

常量字段值

JSON

public static final String JSON

另请参阅:

常量字段值

TEXT

public static final String TEXT

另请参阅:

常量字段值

LONGBLOB

public static final String LONGBLOB

另请参阅:

常量字段值

MAX_CHAR_SIZE

public static final int MAX_CHAR_SIZE

Max size of char type of OceanBase.

另请参阅:

常量字段值

MAX_VARCHAR_SIZE

public static final int MAX_VARCHAR_SIZE

Max size of varchar type of OceanBase.

另请参阅:

常量字段值

MAX_VARBINARY_SIZE

public static final int MAX_VARBINARY_SIZE

The max VARBINARY column length is 1048576.

另请参阅:

常量字段值

构造器详细资料

OceanBaseUtils

public OceanBaseUtils()

方法详细资料

toOceanBaseTable

public static OceanBaseTable toOceanBaseTable(org.apache.flink.cdc.common.event.TableId tableId,
                                              org.apache.flink.cdc.common.schema.Schema schema)

Convert a source table to OceanBaseTable.

toOceanBaseDataType

public static void toOceanBaseDataType(org.apache.flink.cdc.common.schema.Column cdcColumn,
                                       boolean isPrimaryKeys,
                                       OceanBaseColumn.Builder builder)

Convert CDC data type to OceanBase data type.