类的使用
org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseColumn.Builder

使用OceanBaseColumn.Builder的程序包

程序包	说明
org.apache.flink.cdc.connectors.oceanbase.catalog
org.apache.flink.cdc.connectors.oceanbase.sink

org.apache.flink.cdc.connectors.oceanbase.catalog中OceanBaseColumn.Builder的使用

返回OceanBaseColumn.Builder的org.apache.flink.cdc.connectors.oceanbase.catalog中的方法

修饰符和类型	方法	说明
OceanBaseColumn.Builder	OceanBaseColumn.Builder.setColumnComment(String columnComment)
OceanBaseColumn.Builder	OceanBaseColumn.Builder.setColumnName(String columnName)
OceanBaseColumn.Builder	OceanBaseColumn.Builder.setColumnSize(Integer columnSize)
OceanBaseColumn.Builder	OceanBaseColumn.Builder.setDataType(String dataType)
OceanBaseColumn.Builder	OceanBaseColumn.Builder.setDefaultValue(String defaultValue)
OceanBaseColumn.Builder	OceanBaseColumn.Builder.setNullable(boolean isNullable)
OceanBaseColumn.Builder	OceanBaseColumn.Builder.setNumericScale(Integer numericScale)
OceanBaseColumn.Builder	OceanBaseColumn.Builder.setOrdinalPosition(int ordinalPosition)

org.apache.flink.cdc.connectors.oceanbase.sink中OceanBaseColumn.Builder的使用

返回OceanBaseColumn.Builder的org.apache.flink.cdc.connectors.oceanbase.sink中的方法

修饰符和类型	方法	说明
protected OceanBaseColumn.Builder	OceanBaseUtils.CdcDataTypeTransformer.defaultMethod(org.apache.flink.cdc.common.types.DataType dataType)
OceanBaseColumn.Builder	OceanBaseUtils.CdcDataTypeTransformer.visit(org.apache.flink.cdc.common.types.BigIntType bigIntType)
OceanBaseColumn.Builder	OceanBaseUtils.CdcDataTypeTransformer.visit(org.apache.flink.cdc.common.types.BinaryType binaryType)
OceanBaseColumn.Builder	OceanBaseUtils.CdcDataTypeTransformer.visit(org.apache.flink.cdc.common.types.BooleanType booleanType)
OceanBaseColumn.Builder	OceanBaseUtils.CdcDataTypeTransformer.visit(org.apache.flink.cdc.common.types.CharType charType)
OceanBaseColumn.Builder	OceanBaseUtils.CdcDataTypeTransformer.visit(org.apache.flink.cdc.common.types.DateType dateType)
OceanBaseColumn.Builder	OceanBaseUtils.CdcDataTypeTransformer.visit(org.apache.flink.cdc.common.types.DecimalType decimalType)
OceanBaseColumn.Builder	OceanBaseUtils.CdcDataTypeTransformer.visit(org.apache.flink.cdc.common.types.DoubleType doubleType)
OceanBaseColumn.Builder	OceanBaseUtils.CdcDataTypeTransformer.visit(org.apache.flink.cdc.common.types.FloatType floatType)
OceanBaseColumn.Builder	OceanBaseUtils.CdcDataTypeTransformer.visit(org.apache.flink.cdc.common.types.IntType intType)
OceanBaseColumn.Builder	OceanBaseUtils.CdcDataTypeTransformer.visit(org.apache.flink.cdc.common.types.LocalZonedTimestampType localZonedTimestampType)
OceanBaseColumn.Builder	OceanBaseUtils.CdcDataTypeTransformer.visit(org.apache.flink.cdc.common.types.SmallIntType smallIntType)
OceanBaseColumn.Builder	OceanBaseUtils.CdcDataTypeTransformer.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	OceanBaseUtils.CdcDataTypeTransformer.visit(org.apache.flink.cdc.common.types.TimeType timeType)
OceanBaseColumn.Builder	OceanBaseUtils.CdcDataTypeTransformer.visit(org.apache.flink.cdc.common.types.TinyIntType tinyIntType)
OceanBaseColumn.Builder	OceanBaseUtils.CdcDataTypeTransformer.visit(org.apache.flink.cdc.common.types.VarBinaryType bytesType)
OceanBaseColumn.Builder	OceanBaseUtils.CdcDataTypeTransformer.visit(org.apache.flink.cdc.common.types.VarCharType varCharType)
OceanBaseColumn.Builder	OceanBaseUtils.CdcDataTypeTransformer.visit(org.apache.flink.cdc.common.types.ZonedTimestampType zonedTimestampType)

参数类型为OceanBaseColumn.Builder的org.apache.flink.cdc.connectors.oceanbase.sink中的方法

修饰符和类型	方法	说明
static void	OceanBaseUtils.toOceanBaseDataType(org.apache.flink.cdc.common.schema.Column cdcColumn, boolean isPrimaryKeys, OceanBaseColumn.Builder builder)	Convert CDC data type to OceanBase data type.

参数类型为OceanBaseColumn.Builder的org.apache.flink.cdc.connectors.oceanbase.sink中的构造器

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