A B C D E F G I J L M O P R S T U V

A

alterAddColumns(String, String, List<OceanBaseColumn>) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseCatalog

alterAddColumns(String, String, List<OceanBaseColumn>) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseMySQLCatalog

alterAddColumns(String, String, List<OceanBaseColumn>) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseOracleCatalog

alterColumnType(String, String, String, DataType) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseCatalog

alterColumnType(String, String, String, DataType) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseMySQLCatalog

alterColumnType(String, String, String, DataType) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseOracleCatalog

alterDropColumns(String, String, List<String>) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseCatalog

alterDropColumns(String, String, List<String>) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseMySQLCatalog

alterDropColumns(String, String, List<String>) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseOracleCatalog

applySchemaChange(SchemaChangeEvent) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseMetadataApplier

B

BIGINT - 类 中的静态变量org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils

BINARY - 类 中的静态变量org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils

BOOLEAN - 类 中的静态变量org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils

BUFFER_FLUSH_INTERVAL - 类 中的静态变量org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseDataSinkOptions

BUFFER_SIZE - 类 中的静态变量org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseDataSinkOptions

build() - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseColumn.Builder

build() - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseTable.Builder

buildAlterAddColumnsSql(String, String, List<OceanBaseColumn>) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseMySQLCatalog

buildColumnStmt(OceanBaseColumn) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseMySQLCatalog

buildCreateDatabaseSql(String, boolean) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseMySQLCatalog

buildCreateTableSql(OceanBaseTable, boolean) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseMySQLCatalog

Builder() - 类 的构造器org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseColumn.Builder

Builder() - 类 的构造器org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseTable.Builder

C

CdcDataTypeTransformer(boolean, OceanBaseColumn.Builder) - 类 的构造器org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils.CdcDataTypeTransformer

CHAR - 类 中的静态变量org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils

close() - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseCatalog

connectionProvider - 类 中的变量org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseCatalog

createDatabase(String, boolean) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseCatalog

createDatabase(String, boolean) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseMySQLCatalog

Create a database.

createDatabase(String, boolean) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseOracleCatalog

createDataSink(Factory.Context) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.factory.OceanBaseDataSinkFactory

createOceanBaseCatalog(OceanBaseConnectorOptions) - 类 中的静态方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseCatalogFactory

createTable(OceanBaseTable, boolean) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseCatalog

createTable(OceanBaseTable, boolean) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseMySQLCatalog

Creates a table.

createTable(OceanBaseTable, boolean) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseOracleCatalog

D

databaseExists(String) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseCatalog

databaseExists(String) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseMySQLCatalog

Check if a database exists in this catalog.

databaseExists(String) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseOracleCatalog

DATE - 类 中的静态变量org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils

DATETIME - 类 中的静态变量org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils

DECIMAL - 类 中的静态变量org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils

defaultMethod(DataType) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils.CdcDataTypeTransformer

DOUBLE - 类 中的静态变量org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils

DRIVER_CLASS_NAME - 类 中的静态变量org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseDataSinkOptions

dropTable(String, String) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseCatalog

dropTable(String, String) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseMySQLCatalog

dropTable(String, String) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseOracleCatalog

DRUID_PROPERTIES - 类 中的静态变量org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseDataSinkOptions

E

equals(Object) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseColumn

equals(Object) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseTable

executeSingleColumnStatement(String) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseCatalog

executeUpdateStatement(String) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseCatalog

F

FLOAT - 类 中的静态变量org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils

G

getColumn(String) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseTable

getColumnComment() - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseColumn

getColumnName() - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseColumn

getColumns() - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseTable

getColumnSize() - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseColumn

getComment() - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseTable

getDatabaseName() - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseTable

getDataType() - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseColumn

getDefaultValue() - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseColumn

getEventSinkProvider() - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseDataSink

getFullColumnType(String, Optional<Integer>, Optional<Integer>) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseMySQLCatalog

getMetadataApplier() - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseDataSink

getNumericScale() - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseColumn

getOrdinalPosition() - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseColumn

getPartitionKeys() - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseTable

getProperties() - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseTable

getTableKeys() - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseTable

getTableName() - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseTable

getTableType() - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseTable

I

identifier() - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.factory.OceanBaseDataSinkFactory

INT - 类 中的静态变量org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils

isNullable() - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseColumn

J

JSON - 类 中的静态变量org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils

L

ListUtils - org.apache.flink.cdc.connectors.oceanbase.utils中的类

A utility class for List.

ListUtils() - 类 的构造器org.apache.flink.cdc.connectors.oceanbase.utils.ListUtils

LONGBLOB - 类 中的静态变量org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils

M

MAX_CHAR_SIZE - 类 中的静态变量org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils

Max size of char type of OceanBase.

MAX_RETRIES - 类 中的静态变量org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseDataSinkOptions

MAX_VARBINARY_SIZE - 类 中的静态变量org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils

The max VARBINARY column length is 1048576.

MAX_VARCHAR_SIZE - 类 中的静态变量org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils

Max size of varchar type of OceanBase.

MEMSTORE_CHECK_ENABLED - 类 中的静态变量org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseDataSinkOptions

MEMSTORE_CHECK_INTERVAL - 类 中的静态变量org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseDataSinkOptions

MEMSTORE_THRESHOLD - 类 中的静态变量org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseDataSinkOptions

O

OceanBaseCatalog - org.apache.flink.cdc.connectors.oceanbase.catalog中的类

A OceanBaseCatalog for OceanBase connector that supports schema evolution.

OceanBaseCatalog(OceanBaseConnectorOptions) - 类 的构造器org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseCatalog

OceanBaseCatalogException - org.apache.flink.cdc.connectors.oceanbase.catalog中的异常错误

A catalog-related, runtime exception.

OceanBaseCatalogException(String) - 异常错误 的构造器org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseCatalogException

OceanBaseCatalogException(Throwable) - 异常错误 的构造器org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseCatalogException

OceanBaseCatalogException(String, Throwable) - 异常错误 的构造器org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseCatalogException

OceanBaseCatalogFactory - org.apache.flink.cdc.connectors.oceanbase.catalog中的类

A OceanBaseCatalogFactory to create OceanBaseCatalog.

OceanBaseCatalogFactory() - 类 的构造器org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseCatalogFactory

OceanBaseColumn - org.apache.flink.cdc.connectors.oceanbase.catalog中的类

Describe a column of OceanBase table.

OceanBaseColumn.Builder - org.apache.flink.cdc.connectors.oceanbase.catalog中的类

Build a OceanBaseColumn.

OceanBaseDataSink - org.apache.flink.cdc.connectors.oceanbase.sink中的类

A DataSink for "OceanBase" pipeline connector.

OceanBaseDataSink(OceanBaseConnectorOptions, ZoneId) - 类 的构造器org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseDataSink

OceanBaseDataSinkFactory - org.apache.flink.cdc.connectors.oceanbase.factory中的类

A DataSinkFactory to create OceanBaseDataSink.

OceanBaseDataSinkFactory() - 类 的构造器org.apache.flink.cdc.connectors.oceanbase.factory.OceanBaseDataSinkFactory

OceanBaseDataSinkOptions - org.apache.flink.cdc.connectors.oceanbase.sink中的类

Options for OceanBaseDataSink.

OceanBaseDataSinkOptions() - 类 的构造器org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseDataSinkOptions

OceanBaseEventSerializationSchema - org.apache.flink.cdc.connectors.oceanbase.sink中的类

A serializer for Event to Record.

OceanBaseEventSerializationSchema(ZoneId) - 类 的构造器org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseEventSerializationSchema

OceanBaseMetadataApplier - org.apache.flink.cdc.connectors.oceanbase.sink中的类

Supports OceanBaseDataSink to schema evolution.

OceanBaseMetadataApplier(OceanBaseConnectorOptions) - 类 的构造器org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseMetadataApplier

OceanBaseMySQLCatalog - org.apache.flink.cdc.connectors.oceanbase.catalog中的类

A OceanBaseCatalog for OceanBase connector that supports schema evolution under MySQL mode.

OceanBaseMySQLCatalog(OceanBaseConnectorOptions) - 类 的构造器org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseMySQLCatalog

OceanBaseOracleCatalog - org.apache.flink.cdc.connectors.oceanbase.catalog中的类

A OceanBaseCatalog for OceanBase connector that supports schema evolution under Oracle mode.

OceanBaseOracleCatalog(OceanBaseConnectorOptions) - 类 的构造器org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseOracleCatalog

OceanBaseRowConvert - org.apache.flink.cdc.connectors.oceanbase.sink中的类

converter RecordData type object to oceanbase field.

OceanBaseRowConvert() - 类 的构造器org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseRowConvert

OceanBaseTable - org.apache.flink.cdc.connectors.oceanbase.catalog中的类

Describe a OceanBase table.

OceanBaseTable.Builder - org.apache.flink.cdc.connectors.oceanbase.catalog中的类

Build a OceanBaseTable.

OceanBaseTable.TableType - org.apache.flink.cdc.connectors.oceanbase.catalog中的枚举

Types of OceanBase table.

OceanBaseUtils - org.apache.flink.cdc.connectors.oceanbase.sink中的类

Utilities for conversion from source table to OceanBase table.

OceanBaseUtils() - 类 的构造器org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils

OceanBaseUtils.CdcDataTypeTransformer - org.apache.flink.cdc.connectors.oceanbase.sink中的类

Transforms CDC DataType to OceanBase data type.

open() - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseCatalog

optionalOptions() - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.factory.OceanBaseDataSinkFactory

OptionUtils - org.apache.flink.cdc.connectors.oceanbase.utils中的类

A utility class to print configuration of connectors.

org.apache.flink.cdc.connectors.oceanbase.catalog - 程序包 org.apache.flink.cdc.connectors.oceanbase.catalog

org.apache.flink.cdc.connectors.oceanbase.factory - 程序包 org.apache.flink.cdc.connectors.oceanbase.factory

org.apache.flink.cdc.connectors.oceanbase.sink - 程序包 org.apache.flink.cdc.connectors.oceanbase.sink

org.apache.flink.cdc.connectors.oceanbase.utils - 程序包 org.apache.flink.cdc.connectors.oceanbase.utils

P

PARTITION_ENABLED - 类 中的静态变量org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseDataSinkOptions

PASSWORD - 类 中的静态变量org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseDataSinkOptions

pipelineZoneId - 类 中的变量org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseEventSerializationSchema

ZoneId from pipeline config to support timestamp with local time zone.

printOptions(String, Map<String, String>) - 类 中的静态方法org.apache.flink.cdc.connectors.oceanbase.utils.OptionUtils

R

renameColumn(String, String, String, String) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseCatalog

renameColumn(String, String, String, String) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseMySQLCatalog

renameColumn(String, String, String, String) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseOracleCatalog

requiredOptions() - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.factory.OceanBaseDataSinkFactory

S

serialize(Event) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseEventSerializationSchema

serializerRecord(RecordData, Schema) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseEventSerializationSchema

serializer RecordData to oceanbase data change record.

setColumnComment(String) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseColumn.Builder

setColumnName(String) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseColumn.Builder

setColumns(List<OceanBaseColumn>) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseTable.Builder

setColumnSize(Integer) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseColumn.Builder

setComment(String) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseTable.Builder

setDatabaseName(String) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseTable.Builder

setDataType(String) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseColumn.Builder

setDefaultValue(String) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseColumn.Builder

setNullable(boolean) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseColumn.Builder

setNumericScale(Integer) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseColumn.Builder

setOrdinalPosition(int) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseColumn.Builder

setPartitionKeys(List<String>) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseTable.Builder

setTableKeys(List<String>) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseTable.Builder

setTableName(String) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseTable.Builder

setTableProperties(Map<String, String>) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseTable.Builder

setTableType(OceanBaseTable.TableType) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseTable.Builder

SMALLINT - 类 中的静态变量org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils

STRING - 类 中的静态变量org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils

SYNC_WRITE - 类 中的静态变量org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseDataSinkOptions

T

tableExists(String, String) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseCatalog

tableExists(String, String) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseMySQLCatalog

tableExists(String, String) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseOracleCatalog

TEXT - 类 中的静态变量org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils

TIME - 类 中的静态变量org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils

TIMESTAMP - 类 中的静态变量org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils

TINYINT - 类 中的静态变量org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils

toOceanBaseDataType(Column, boolean, OceanBaseColumn.Builder) - 类 中的静态方法org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils

Convert CDC data type to OceanBase data type.

toOceanBaseTable(TableId, Schema) - 类 中的静态方法org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils

Convert a source table to OceanBaseTable.

toString() - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseColumn

toString() - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseTable

truncateTable(String, String) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseCatalog

truncateTable(String, String) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseMySQLCatalog

truncateTable(String, String) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseOracleCatalog

U

union(List<T>, List<T>) - 类 中的静态方法org.apache.flink.cdc.connectors.oceanbase.utils.ListUtils

URL - 类 中的静态变量org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseDataSinkOptions

USERNAME - 类 中的静态变量org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseDataSinkOptions

V

valueOf(String) - 枚举 中的静态方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseTable.TableType

返回带有指定名称的该类型的枚举常量。

values() - 枚举 中的静态方法org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseTable.TableType

按照声明该枚举类型的常量的顺序, 返回 包含这些常量的数组。

VARBINARY - 类 中的静态变量org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils

VARCHAR - 类 中的静态变量org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils

visit(BooleanType) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils.CdcDataTypeTransformer

visit(TinyIntType) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils.CdcDataTypeTransformer

visit(SmallIntType) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils.CdcDataTypeTransformer

visit(IntType) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils.CdcDataTypeTransformer

visit(BigIntType) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils.CdcDataTypeTransformer

visit(BinaryType) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils.CdcDataTypeTransformer

visit(VarBinaryType) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils.CdcDataTypeTransformer

visit(FloatType) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils.CdcDataTypeTransformer

visit(DoubleType) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils.CdcDataTypeTransformer

visit(DecimalType) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils.CdcDataTypeTransformer

visit(CharType) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils.CdcDataTypeTransformer

visit(VarCharType) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils.CdcDataTypeTransformer

visit(DateType) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils.CdcDataTypeTransformer

visit(TimeType) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils.CdcDataTypeTransformer

visit(TimestampType) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils.CdcDataTypeTransformer

The maximum precision of the TIMESTAMP and DATETIME type is 6 in OceanBase. 1.

visit(ZonedTimestampType) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils.CdcDataTypeTransformer

visit(LocalZonedTimestampType) - 类 中的方法org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseUtils.CdcDataTypeTransformer

A B C D E F G I J L M O P R S T U V