类的使用
org.apache.flink.cdc.common.types.DataType

使用DataType的程序包

程序包	说明
org.apache.flink.cdc.common.data
org.apache.flink.cdc.common.data.binary
org.apache.flink.cdc.common.event
org.apache.flink.cdc.common.schema
org.apache.flink.cdc.common.source
org.apache.flink.cdc.common.types
org.apache.flink.cdc.common.types.utils
org.apache.flink.cdc.common.udf
org.apache.flink.cdc.common.utils

org.apache.flink.cdc.common.data中DataType的使用

参数类型为DataType的org.apache.flink.cdc.common.data中的方法

限定符和类型	方法和说明
static ArrayData.ElementGetter	ArrayData.createElementGetter(DataType elementType) Creates an accessor for getting elements in an internal array data structure at the given position.
static RecordData.FieldGetter	RecordData.createFieldGetter(DataType fieldType, int fieldPos) Creates an accessor for getting elements in an internal RecordData structure at the given position.

org.apache.flink.cdc.common.data.binary中DataType的使用

参数类型为DataType的org.apache.flink.cdc.common.data.binary中的方法

限定符和类型	方法和说明
static int	BinaryArrayData.calculateFixLengthPartSize(DataType type) It store real value when type is primitive.
Map<?,?>	BinaryMapData.toJavaMap(DataType keyType, DataType valueType)
<T> T[]	BinaryArrayData.toObjectArray(DataType elementType)

org.apache.flink.cdc.common.event中DataType的使用

返回变量类型为DataType的类型的org.apache.flink.cdc.common.event中的方法

限定符和类型	方法和说明
Map<String,DataType>	AlterColumnTypeEvent.getOldTypeMapping()
Map<String,DataType>	AlterColumnTypeEvent.getTypeMapping() Returns the type mapping.

类型变量类型为DataType的org.apache.flink.cdc.common.event中的构造器参数

构造器和说明
AlterColumnTypeEvent(TableId tableId, Map<String,DataType> typeMapping)
AlterColumnTypeEvent(TableId tableId, Map<String,DataType> typeMapping, Map<String,DataType> oldTypeMapping)
AlterColumnTypeEvent(TableId tableId, Map<String,DataType> typeMapping, Map<String,DataType> oldTypeMapping)

org.apache.flink.cdc.common.schema中DataType的使用

声明为DataType的org.apache.flink.cdc.common.schema中的字段

限定符和类型	字段和说明
protected DataType	Column.type

返回DataType的org.apache.flink.cdc.common.schema中的方法

限定符和类型	方法和说明
DataType	Column.getType() Returns the data type of this column.
DataType	Schema.toRowDataType() Converts all columns of this schema into a (possibly nested) row data type.

返回变量类型为DataType的类型的org.apache.flink.cdc.common.schema中的方法

限定符和类型	方法和说明
List<DataType>	Schema.getColumnDataTypes() Returns all column data types.

参数类型为DataType的org.apache.flink.cdc.common.schema中的方法

限定符和类型	方法和说明
abstract Column	Column.copy(DataType newType) Returns a copy of the column with a replaced DataType.
Column	MetadataColumn.copy(DataType newType)
Column	PhysicalColumn.copy(DataType newType)
Schema.Builder	Schema.Builder.fromRowDataType(DataType type) Adopts all fields of the given row as physical columns of the schema.
Schema.Builder	Schema.Builder.metadataColumn(String columnName, DataType type) Declares a metadata column that is appended to this schema.
static MetadataColumn	Column.metadataColumn(String name, DataType type) Creates a metadata column.
Schema.Builder	Schema.Builder.metadataColumn(String columnName, DataType type, String metadataKey) Declares a metadata column that is appended to this schema.
static MetadataColumn	Column.metadataColumn(String name, DataType type, String metadataKey) Creates a metadata column.
Schema.Builder	Schema.Builder.metadataColumn(String columnName, DataType type, String metadataKey, String comment) Declares a metadata column that is appended to this schema.
static MetadataColumn	Column.metadataColumn(String name, DataType type, String metadataKey, String comment) Creates a metadata column.
Schema.Builder	Schema.Builder.physicalColumn(String columnName, DataType type) Declares a physical column that is appended to this schema.
static PhysicalColumn	Column.physicalColumn(String name, DataType type) Creates a physical column.
Schema.Builder	Schema.Builder.physicalColumn(String columnName, DataType type, String comment) Declares a physical column that is appended to this schema.
static PhysicalColumn	Column.physicalColumn(String name, DataType type, String comment) Creates a physical column.
Schema.Builder	Schema.Builder.physicalColumn(String columnName, DataType type, String comment, String defaultValue) Declares a physical column that is appended to this schema.
static PhysicalColumn	Column.physicalColumn(String name, DataType type, String comment, String defaultValueExpression) Creates a physical column.

参数类型为DataType的org.apache.flink.cdc.common.schema中的构造器

构造器和说明
Column(String name, DataType type, String comment)
Column(String name, DataType type, String comment, String defaultValueExpression)
MetadataColumn(String name, DataType type, String metadataKey, String comment)
PhysicalColumn(String name, DataType type, String comment)
PhysicalColumn(String name, DataType type, String comment, String defaultValue)

org.apache.flink.cdc.common.source中DataType的使用

返回DataType的org.apache.flink.cdc.common.source中的方法

限定符和类型	方法和说明
DataType	SupportedMetadataColumn.getType() The data type of this column in Flink CDC.

org.apache.flink.cdc.common.types中DataType的使用

org.apache.flink.cdc.common.types中DataType的子类

限定符和类型	类和说明
class	ArrayType Data type of an array of elements with same subtype.
class	BigIntType Data type of an 8-byte signed integer with values from -9,223,372,036,854,775,808 to 9,223,372,036,854,775,807.
class	BinaryType Data type of a fixed-length binary string (=a sequence of bytes).
class	BooleanType Data type of a boolean with a (possibly) three-valued logic of TRUE, FALSE, UNKNOWN.
class	CharType Data type of a fixed-length character string.
class	DateType Data type of a date consisting of year-month-day with values ranging from 0000-01-01 to 9999-12-31.
class	DecimalType Data type of a decimal number with fixed precision and scale.
class	DoubleType Data type of an 8-byte double precision floating point number.
class	FloatType Data type of a 4-byte single precision floating point number.
class	IntType Data type of a 4-byte signed integer with values from -2,147,483,648 to 2,147,483,647.
class	LocalZonedTimestampType Data type of a timestamp WITH LOCAL time zone consisting of year-month-day hour:minute:second[.fractional] zone with up to nanosecond precision and values ranging from 0000-01-01 00:00:00.000000000 +14:59 to 9999-12-31 23:59:59.999999999 -14:59.
class	MapType Data type of an associative array that maps keys (including NULL) to values (including NULL).
class	RowType Data type of a sequence of fields.
class	SmallIntType Data type of a 2-byte signed integer with values from -32,768 to 32,767.
class	TimestampType Data type of a timestamp WITHOUT time zone consisting of year-month-day hour:minute:second[.fractional] with up to nanosecond precision and values ranging from 0000-01-01 00:00:00.000000000 to 9999-12-31 23:59:59.999999999.
class	TimeType Data type of a time WITHOUT time zone consisting of hour:minute:second[.fractional] with up to nanosecond precision and values ranging from 00:00:00.000000000 to 23:59:59.999999999.
class	TinyIntType Data type of a 1-byte signed integer with values from -128 to 127.
class	VarBinaryType Data type of a variable-length binary string (=a sequence of bytes).
class	VarCharType Data type of a variable-length character string.
class	ZonedTimestampType Data type of a timestamp WITH time zone consisting of year-month-day hour:minute:second[.fractional] zone with up to nanosecond precision and values ranging from 0000-01-01 00:00:00.000000000 +14:59 to 9999-12-31 23:59:59.999999999 -14:59.

返回DataType的org.apache.flink.cdc.common.types中的方法

限定符和类型	方法和说明
DataType	DataType.copy() Returns a deep copy of this type.
DataType	DateType.copy(boolean isNullable)
DataType	LocalZonedTimestampType.copy(boolean isNullable)
DataType	TimestampType.copy(boolean isNullable)
DataType	BooleanType.copy(boolean isNullable)
DataType	VarBinaryType.copy(boolean isNullable)
DataType	DoubleType.copy(boolean isNullable)
DataType	FloatType.copy(boolean isNullable)
DataType	CharType.copy(boolean isNullable)
DataType	TimeType.copy(boolean isNullable)
DataType	VarCharType.copy(boolean isNullable)
DataType	DecimalType.copy(boolean isNullable)
DataType	RowType.copy(boolean isNullable)
DataType	ZonedTimestampType.copy(boolean isNullable)
DataType	IntType.copy(boolean isNullable)
DataType	ArrayType.copy(boolean isNullable)
abstract DataType	DataType.copy(boolean isNullable) Returns a deep copy of this type with possibly different nullability.
DataType	BigIntType.copy(boolean isNullable)
DataType	BinaryType.copy(boolean isNullable)
DataType	TinyIntType.copy(boolean isNullable)
DataType	SmallIntType.copy(boolean isNullable)
DataType	MapType.copy(boolean isNullable)
DataType	ArrayType.getElementType()
DataType	MapType.getKeyType()
DataType	DataField.getType()
DataType	RowType.getTypeAt(int i)
DataType	MapType.getValueType()
DataType	DataType.notNull()
DataType	DataType.nullable()
static DataType	DataTypes.STRING() Data type of a variable-length character string with defined maximum length.
static DataType	DataTypes.VARCHAR(int n) Data type of a variable-length character string VARCHAR(n) where n is the maximum number of code points.

返回变量类型为DataType的类型的org.apache.flink.cdc.common.types中的方法

限定符和类型	方法和说明
List<DataType>	DateType.getChildren()
List<DataType>	LocalZonedTimestampType.getChildren()
List<DataType>	TimestampType.getChildren()
List<DataType>	BooleanType.getChildren()
List<DataType>	VarBinaryType.getChildren()
List<DataType>	DoubleType.getChildren()
List<DataType>	FloatType.getChildren()
List<DataType>	CharType.getChildren()
List<DataType>	TimeType.getChildren()
List<DataType>	VarCharType.getChildren()
List<DataType>	DecimalType.getChildren()
List<DataType>	RowType.getChildren()
List<DataType>	ZonedTimestampType.getChildren()
List<DataType>	IntType.getChildren()
List<DataType>	ArrayType.getChildren()
abstract List<DataType>	DataType.getChildren()
List<DataType>	BigIntType.getChildren()
List<DataType>	BinaryType.getChildren()
List<DataType>	TinyIntType.getChildren()
List<DataType>	SmallIntType.getChildren()
List<DataType>	MapType.getChildren()
List<DataType>	RowType.getFieldTypes()
static List<DataType>	DataTypeChecks.getFieldTypes(DataType dataType) Returns the field types of row and structured types.
static List<DataType>	DataTypeChecks.getNestedTypes(DataType dataType)

参数类型为DataType的org.apache.flink.cdc.common.types中的方法

限定符和类型	方法和说明
static ArrayType	DataTypes.ARRAY(DataType element) Data type of an array of elements with same subtype.
protected abstract R	DataTypeDefaultVisitor.defaultMethod(DataType dataType)
RowType.Builder	RowType.Builder.field(String name, DataType type)
static DataField	DataTypes.FIELD(String name, DataType type) Field definition with field name and data type.
RowType.Builder	RowType.Builder.field(String name, DataType type, String description)
static DataField	DataTypes.FIELD(String name, DataType type, String description) Field definition with field name, data type, and a description.
RowType.Builder	RowType.Builder.fields(DataType... types)
RowType.Builder	RowType.Builder.fields(DataType[] types, String[] names)
static int	DataTypeChecks.getFieldCount(DataType dataType) Returns the field count of row and structured types.
static List<String>	DataTypeChecks.getFieldNames(DataType dataType) Returns the field names of row and structured types.
static List<DataType>	DataTypeChecks.getFieldTypes(DataType dataType) Returns the field types of row and structured types.
static OptionalInt	DataTypes.getLength(DataType dataType)
static int	DataTypeChecks.getLength(DataType dataType)
static List<DataType>	DataTypeChecks.getNestedTypes(DataType dataType)
static OptionalInt	DataTypes.getPrecision(DataType dataType)
static int	DataTypeChecks.getPrecision(DataType dataType) Returns the precision of all types that define a precision implicitly or explicitly.
static OptionalInt	DataTypes.getScale(DataType dataType)
static int	DataTypeChecks.getScale(DataType dataType) Returns the scale of all types that define a scale implicitly or explicitly.
static boolean	DataTypeChecks.hasLength(DataType dataType, int length)
static boolean	DataTypeChecks.hasPrecision(DataType dataType, int precision) Checks the precision of a type that defines a precision implicitly or explicitly.
static boolean	DataTypeChecks.hasScale(DataType dataType, int scale) Checks the scale of all types that define a scale implicitly or explicitly.
static boolean	DataTypeChecks.hasWellDefinedString(DataType dataType) Checks whether the given DataType has a well-defined string representation when calling Object.toString() on the internal data structure.
static boolean	DataTypeChecks.isCompositeType(DataType dataType) Checks if the given type is a composite type.
static MapType	DataTypes.MAP(DataType keyType, DataType valueType) Data type of an associative array that maps keys (including NULL) to values (including NULL).
static RowType	RowType.of(boolean isNullable, DataType... types)
static RowType	RowType.of(boolean nullable, DataType[] types, String[] names)
static RowType	RowType.of(DataType... types)
static RowType	RowType.of(DataType[] types, String[] names)
static RowType	DataTypes.ROW(DataType... fieldTypes) Data type of a sequence of fields.

类型变量类型为DataType的org.apache.flink.cdc.common.types中的方法参数

限定符和类型	方法和说明
RowType.Builder	RowType.Builder.fields(List<DataType> types)

参数类型为DataType的org.apache.flink.cdc.common.types中的构造器

构造器和说明
ArrayType(boolean isNullable, DataType elementType)
ArrayType(DataType elementType)
DataField(String name, DataType type)
DataField(String name, DataType type, String description)
MapType(boolean isNullable, DataType keyType, DataType valueType)
MapType(DataType keyType, DataType valueType)

org.apache.flink.cdc.common.types.utils中DataType的使用

参数类型为DataType的org.apache.flink.cdc.common.types.utils中的方法

限定符和类型	方法和说明
static org.apache.flink.table.types.DataType	DataTypeUtils.toFlinkDataType(DataType type) Convert CDC's DataType to Flink's internal DataType.
static Class<?>	DataTypeUtils.toInternalConversionClass(DataType type) Returns the conversion class for the given DataType that is used by the table runtime as internal data structure.

org.apache.flink.cdc.common.udf中DataType的使用

返回DataType的org.apache.flink.cdc.common.udf中的方法

限定符和类型	方法和说明
default DataType	UserDefinedFunction.getReturnType()

org.apache.flink.cdc.common.utils中DataType的使用

返回DataType的org.apache.flink.cdc.common.utils中的方法

限定符和类型	方法和说明
static DataType	SchemaUtils.inferWiderType(DataType lType, DataType rType) 已过时。 Use getLeastCommonType in SchemaMergingUtils instead.

参数类型为DataType的org.apache.flink.cdc.common.utils中的方法

限定符和类型	方法和说明
static int	SchemaUtils.getNumericPrecision(DataType dataType) 已过时。
static int	SchemaMergingUtils.getNumericPrecision(DataType dataType)
static DataType	SchemaUtils.inferWiderType(DataType lType, DataType rType) 已过时。 Use getLeastCommonType in SchemaMergingUtils instead.
static boolean	TypeCheckUtils.isArray(DataType type)
static boolean	TypeCheckUtils.isBinaryString(DataType type)
static boolean	TypeCheckUtils.isBoolean(DataType type)
static boolean	TypeCheckUtils.isCharacterString(DataType type)
static boolean	TypeCheckUtils.isComparable(DataType type)
static boolean	TypeCheckUtils.isDecimal(DataType type)
static boolean	TypeCheckUtils.isInteger(DataType type)
static boolean	TypeCheckUtils.isLong(DataType type)
static boolean	TypeCheckUtils.isMap(DataType type)
static boolean	TypeCheckUtils.isMutable(DataType type)
static boolean	TypeCheckUtils.isNumeric(DataType type)
static boolean	TypeCheckUtils.isReference(DataType type)
static boolean	TypeCheckUtils.isRow(DataType type)
static boolean	TypeCheckUtils.isTemporal(DataType type)
static boolean	TypeCheckUtils.isTimePoint(DataType type)
static boolean	TypeCheckUtils.isTimestamp(DataType type)
static boolean	TypeCheckUtils.isTimestampWithLocalZone(DataType type)
static boolean	TypeCheckUtils.isTimestampWithTimeZone(DataType type)