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

类 OceanBaseUtils.CdcDataTypeTransformer

java.lang.Object

org.apache.flink.cdc.common.types.DataTypeDefaultVisitor<OceanBaseColumn.Builder>

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

所有已实现的接口:

org.apache.flink.cdc.common.types.DataTypeVisitor<OceanBaseColumn.Builder>

封闭类:

OceanBaseUtils

public static class OceanBaseUtils.CdcDataTypeTransformer
extends org.apache.flink.cdc.common.types.DataTypeDefaultVisitor<OceanBaseColumn.Builder>

Transforms CDC DataType to OceanBase data type.

构造器概要

构造器

构造器	说明
CdcDataTypeTransformer(boolean isPrimaryKeys, OceanBaseColumn.Builder builder)

方法概要

修饰符和类型	方法	说明
protected OceanBaseColumn.Builder	defaultMethod(org.apache.flink.cdc.common.types.DataType dataType)
OceanBaseColumn.Builder	visit(org.apache.flink.cdc.common.types.BigIntType bigIntType)
OceanBaseColumn.Builder	visit(org.apache.flink.cdc.common.types.BinaryType binaryType)
OceanBaseColumn.Builder	visit(org.apache.flink.cdc.common.types.BooleanType booleanType)
OceanBaseColumn.Builder	visit(org.apache.flink.cdc.common.types.CharType charType)
OceanBaseColumn.Builder	visit(org.apache.flink.cdc.common.types.DateType dateType)
OceanBaseColumn.Builder	visit(org.apache.flink.cdc.common.types.DecimalType decimalType)
OceanBaseColumn.Builder	visit(org.apache.flink.cdc.common.types.DoubleType doubleType)
OceanBaseColumn.Builder	visit(org.apache.flink.cdc.common.types.FloatType floatType)
OceanBaseColumn.Builder	visit(org.apache.flink.cdc.common.types.IntType intType)
OceanBaseColumn.Builder	visit(org.apache.flink.cdc.common.types.LocalZonedTimestampType localZonedTimestampType)
OceanBaseColumn.Builder	visit(org.apache.flink.cdc.common.types.SmallIntType smallIntType)
OceanBaseColumn.Builder	visit(org.apache.flink.cdc.common.types.TimestampType timestampType)	The maximum precision of the TIMESTAMP and DATETIME type is 6 in OceanBase. 1.
OceanBaseColumn.Builder	visit(org.apache.flink.cdc.common.types.TimeType timeType)
OceanBaseColumn.Builder	visit(org.apache.flink.cdc.common.types.TinyIntType tinyIntType)
OceanBaseColumn.Builder	visit(org.apache.flink.cdc.common.types.VarBinaryType bytesType)
OceanBaseColumn.Builder	visit(org.apache.flink.cdc.common.types.VarCharType varCharType)
OceanBaseColumn.Builder	visit(org.apache.flink.cdc.common.types.ZonedTimestampType zonedTimestampType)

从类继承的方法 org.apache.flink.cdc.common.types.DataTypeDefaultVisitor

visit, visit, visit

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

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

从接口继承的方法 org.apache.flink.cdc.common.types.DataTypeVisitor

visit

构造器详细资料

CdcDataTypeTransformer

public CdcDataTypeTransformer(boolean isPrimaryKeys,
                              OceanBaseColumn.Builder builder)

方法详细资料

visit

public OceanBaseColumn.Builder visit(org.apache.flink.cdc.common.types.BooleanType booleanType)

指定者:

visit 在接口中 org.apache.flink.cdc.common.types.DataTypeVisitor<OceanBaseColumn.Builder>

覆盖:

visit 在类中 org.apache.flink.cdc.common.types.DataTypeDefaultVisitor<OceanBaseColumn.Builder>

visit

public OceanBaseColumn.Builder visit(org.apache.flink.cdc.common.types.TinyIntType tinyIntType)

指定者:

visit 在接口中 org.apache.flink.cdc.common.types.DataTypeVisitor<OceanBaseColumn.Builder>

覆盖:

visit 在类中 org.apache.flink.cdc.common.types.DataTypeDefaultVisitor<OceanBaseColumn.Builder>

visit

public OceanBaseColumn.Builder visit(org.apache.flink.cdc.common.types.SmallIntType smallIntType)

指定者:

visit 在接口中 org.apache.flink.cdc.common.types.DataTypeVisitor<OceanBaseColumn.Builder>

覆盖:

visit 在类中 org.apache.flink.cdc.common.types.DataTypeDefaultVisitor<OceanBaseColumn.Builder>

visit

public OceanBaseColumn.Builder visit(org.apache.flink.cdc.common.types.IntType intType)

指定者:

visit 在接口中 org.apache.flink.cdc.common.types.DataTypeVisitor<OceanBaseColumn.Builder>

覆盖:

visit 在类中 org.apache.flink.cdc.common.types.DataTypeDefaultVisitor<OceanBaseColumn.Builder>

visit

public OceanBaseColumn.Builder visit(org.apache.flink.cdc.common.types.BigIntType bigIntType)

指定者:

visit 在接口中 org.apache.flink.cdc.common.types.DataTypeVisitor<OceanBaseColumn.Builder>

覆盖:

visit 在类中 org.apache.flink.cdc.common.types.DataTypeDefaultVisitor<OceanBaseColumn.Builder>

visit

public OceanBaseColumn.Builder visit(org.apache.flink.cdc.common.types.BinaryType binaryType)

指定者:

visit 在接口中 org.apache.flink.cdc.common.types.DataTypeVisitor<OceanBaseColumn.Builder>

覆盖:

visit 在类中 org.apache.flink.cdc.common.types.DataTypeDefaultVisitor<OceanBaseColumn.Builder>

visit

public OceanBaseColumn.Builder visit(org.apache.flink.cdc.common.types.VarBinaryType bytesType)

指定者:

visit 在接口中 org.apache.flink.cdc.common.types.DataTypeVisitor<OceanBaseColumn.Builder>

覆盖:

visit 在类中 org.apache.flink.cdc.common.types.DataTypeDefaultVisitor<OceanBaseColumn.Builder>

visit

public OceanBaseColumn.Builder visit(org.apache.flink.cdc.common.types.FloatType floatType)

指定者:

visit 在接口中 org.apache.flink.cdc.common.types.DataTypeVisitor<OceanBaseColumn.Builder>

覆盖:

visit 在类中 org.apache.flink.cdc.common.types.DataTypeDefaultVisitor<OceanBaseColumn.Builder>

visit

public OceanBaseColumn.Builder visit(org.apache.flink.cdc.common.types.DoubleType doubleType)

指定者:

visit 在接口中 org.apache.flink.cdc.common.types.DataTypeVisitor<OceanBaseColumn.Builder>

覆盖:

visit 在类中 org.apache.flink.cdc.common.types.DataTypeDefaultVisitor<OceanBaseColumn.Builder>

visit

public OceanBaseColumn.Builder visit(org.apache.flink.cdc.common.types.DecimalType decimalType)

指定者:

visit 在接口中 org.apache.flink.cdc.common.types.DataTypeVisitor<OceanBaseColumn.Builder>

覆盖:

visit 在类中 org.apache.flink.cdc.common.types.DataTypeDefaultVisitor<OceanBaseColumn.Builder>

visit

public OceanBaseColumn.Builder visit(org.apache.flink.cdc.common.types.CharType charType)

指定者:

visit 在接口中 org.apache.flink.cdc.common.types.DataTypeVisitor<OceanBaseColumn.Builder>

覆盖:

visit 在类中 org.apache.flink.cdc.common.types.DataTypeDefaultVisitor<OceanBaseColumn.Builder>

visit

public OceanBaseColumn.Builder visit(org.apache.flink.cdc.common.types.VarCharType varCharType)

指定者:

visit 在接口中 org.apache.flink.cdc.common.types.DataTypeVisitor<OceanBaseColumn.Builder>

覆盖:

visit 在类中 org.apache.flink.cdc.common.types.DataTypeDefaultVisitor<OceanBaseColumn.Builder>

visit

public OceanBaseColumn.Builder visit(org.apache.flink.cdc.common.types.DateType dateType)

指定者:

visit 在接口中 org.apache.flink.cdc.common.types.DataTypeVisitor<OceanBaseColumn.Builder>

覆盖:

visit 在类中 org.apache.flink.cdc.common.types.DataTypeDefaultVisitor<OceanBaseColumn.Builder>

visit

public OceanBaseColumn.Builder visit(org.apache.flink.cdc.common.types.TimeType timeType)

指定者:

visit 在接口中 org.apache.flink.cdc.common.types.DataTypeVisitor<OceanBaseColumn.Builder>

覆盖:

visit 在类中 org.apache.flink.cdc.common.types.DataTypeDefaultVisitor<OceanBaseColumn.Builder>

visit

public OceanBaseColumn.Builder visit(org.apache.flink.cdc.common.types.TimestampType timestampType)

The maximum precision of the TIMESTAMP and DATETIME type is 6 in OceanBase. 1. TimestampType with timezone mapping to type TIMESTAMP in oceanbase 2. TimestampType without timezone mapping to type DATETIME in oceanbase

指定者:

visit 在接口中 org.apache.flink.cdc.common.types.DataTypeVisitor<OceanBaseColumn.Builder>

覆盖:

visit 在类中 org.apache.flink.cdc.common.types.DataTypeDefaultVisitor<OceanBaseColumn.Builder>

visit

public OceanBaseColumn.Builder visit(org.apache.flink.cdc.common.types.ZonedTimestampType zonedTimestampType)

指定者:

visit 在接口中 org.apache.flink.cdc.common.types.DataTypeVisitor<OceanBaseColumn.Builder>

覆盖:

visit 在类中 org.apache.flink.cdc.common.types.DataTypeDefaultVisitor<OceanBaseColumn.Builder>

visit

public OceanBaseColumn.Builder visit(org.apache.flink.cdc.common.types.LocalZonedTimestampType localZonedTimestampType)

指定者:

visit 在接口中 org.apache.flink.cdc.common.types.DataTypeVisitor<OceanBaseColumn.Builder>

覆盖:

visit 在类中 org.apache.flink.cdc.common.types.DataTypeDefaultVisitor<OceanBaseColumn.Builder>

defaultMethod

protected OceanBaseColumn.Builder defaultMethod(org.apache.flink.cdc.common.types.DataType dataType)

指定者:

defaultMethod 在类中 org.apache.flink.cdc.common.types.DataTypeDefaultVisitor<OceanBaseColumn.Builder>