public static class OceanBaseUtils.CdcDataTypeTransformer extends org.apache.flink.cdc.common.types.DataTypeDefaultVisitor<OceanBaseColumn.Builder>
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) |
public CdcDataTypeTransformer(boolean isPrimaryKeys,
OceanBaseColumn.Builder builder)
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>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>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>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>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>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>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>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>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>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>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>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>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>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>public OceanBaseColumn.Builder visit(org.apache.flink.cdc.common.types.TimestampType timestampType)
visit 在接口中 org.apache.flink.cdc.common.types.DataTypeVisitor<OceanBaseColumn.Builder>visit 在类中 org.apache.flink.cdc.common.types.DataTypeDefaultVisitor<OceanBaseColumn.Builder>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>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>protected OceanBaseColumn.Builder defaultMethod(org.apache.flink.cdc.common.types.DataType dataType)
defaultMethod 在类中 org.apache.flink.cdc.common.types.DataTypeDefaultVisitor<OceanBaseColumn.Builder>Copyright © 2025 The Apache Software Foundation. All rights reserved.