Uses of Class
org.apache.flink.table.types.DataType

Packages that use DataType

Package	Description
org.apache.flink.table.api
org.apache.flink.table.expressions
org.apache.flink.table.functions
org.apache.flink.table.sinks
org.apache.flink.table.sources
org.apache.flink.table.types
org.apache.flink.table.types.inference
org.apache.flink.table.types.inference.strategies
org.apache.flink.table.types.utils

Uses of DataType in org.apache.flink.table.api

Methods in org.apache.flink.table.api that return DataType

Modifier and Type	Method and Description
static <T> DataType	DataTypes.ANY(Class<T> clazz, org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer) Data type of an arbitrary serialized type.
static <T> DataType	DataTypes.ANY(org.apache.flink.api.common.typeinfo.TypeInformation<T> typeInformation) Data type of an arbitrary serialized type backed by TypeInformation.
static DataType	DataTypes.ARRAY(DataType elementDataType) Data type of an array of elements with same subtype.
static DataType	DataTypes.BIGINT() 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.
static DataType	DataTypes.BINARY(int n) Data type of a fixed-length binary string (=a sequence of bytes) BINARY(n) where n is the number of bytes.
static DataType	DataTypes.BOOLEAN() Data type of a boolean with a (possibly) three-valued logic of TRUE, FALSE, UNKNOWN.
static DataType	DataTypes.BYTES() Data type of a variable-length binary string (=a sequence of bytes) with defined maximum length.
static DataType	DataTypes.CHAR(int n) Data type of a fixed-length character string CHAR(n) where n is the number of code points.
static DataType	DataTypes.DATE() Data type of a date consisting of year-month-day with values ranging from 0000-01-01 to 9999-12-31.
static DataType	DataTypes.DECIMAL(int precision, int scale) Data type of a decimal number with fixed precision and scale DECIMAL(p, s) where p is the number of digits in a number (=precision) and s is the number of digits to the right of the decimal point in a number (=scale).
static DataType	DataTypes.DOUBLE() Data type of an 8-byte double precision floating point number.
static DataType	DataTypes.FLOAT() Data type of a 4-byte single precision floating point number.
DataType	DataTypes.Field.getDataType()
DataType[]	TableSchema.getFieldDataTypes() Returns all field data types as an array.
static DataType	DataTypes.INT() Data type of a 4-byte signed integer with values from -2,147,483,648 to 2,147,483,647.
static DataType	DataTypes.INTERVAL(DataTypes.Resolution resolution) Data type of a temporal interval.
static DataType	DataTypes.INTERVAL(DataTypes.Resolution upperResolution, DataTypes.Resolution lowerResolution) Data type of a temporal interval.
static DataType	DataTypes.MAP(DataType keyDataType, DataType valueDataType) Data type of an associative array that maps keys (including NULL) to values (including NULL).
static DataType	DataTypes.MULTISET(DataType elementDataType) Data type of a multiset (=bag).
static DataType	DataTypes.NULL() Data type for representing untyped NULL values.
static DataType	DataTypes.ROW(DataTypes.Field... fields) Data type of a sequence of fields.
static DataType	DataTypes.SMALLINT() Data type of a 2-byte signed integer with values from -32,768 to 32,767.
static DataType	DataTypes.STRING() Data type of a variable-length character string with defined maximum length.
static DataType	DataTypes.TIME() Data type of a time WITHOUT time zone TIME with no fractional seconds by default.
static DataType	DataTypes.TIME(int precision) Data type of a time WITHOUT time zone TIME(p) where p is the number of digits of fractional seconds (=precision).
static DataType	DataTypes.TIMESTAMP_WITH_LOCAL_TIME_ZONE() Data type of a timestamp WITH LOCAL time zone TIMESTAMP WITH LOCAL TIME ZONE with 6 digits of fractional seconds by default.
static DataType	DataTypes.TIMESTAMP_WITH_LOCAL_TIME_ZONE(int precision) Data type of a timestamp WITH LOCAL time zone TIMESTAMP(p) WITH LOCAL TIME ZONE where p is the number of digits of fractional seconds (=precision).
static DataType	DataTypes.TIMESTAMP_WITH_TIME_ZONE() Data type of a timestamp WITH time zone TIMESTAMP WITH TIME ZONE with 6 digits of fractional seconds by default.
static DataType	DataTypes.TIMESTAMP_WITH_TIME_ZONE(int precision) Data type of a timestamp WITH time zone TIMESTAMP(p) WITH TIME ZONE where p is the number of digits of fractional seconds (=precision).
static DataType	DataTypes.TIMESTAMP() Data type of a timestamp WITHOUT time zone TIMESTAMP with 6 digits of fractional seconds by default.
static DataType	DataTypes.TIMESTAMP(int precision) Data type of a timestamp WITHOUT time zone TIMESTAMP(p) where p is the number of digits of fractional seconds (=precision).
static DataType	DataTypes.TINYINT() Data type of a 1-byte signed integer with values from -128 to 127.
DataType	TableSchema.toRowDataType() Converts a table schema into a (nested) data type describing a DataTypes.ROW(Field...).
static DataType	DataTypes.VARBINARY(int n) Data type of a variable-length binary string (=a sequence of bytes) VARBINARY(n) where n is the maximum number of bytes.
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.

Methods in org.apache.flink.table.api that return types with arguments of type DataType

Modifier and Type	Method and Description
Optional<DataType>	TableSchema.getFieldDataType(int fieldIndex) Returns the specified data type for the given field index.
Optional<DataType>	TableSchema.getFieldDataType(String fieldName) Returns the specified data type for the given field name.

Methods in org.apache.flink.table.api with parameters of type DataType

Modifier and Type	Method and Description
static DataType	DataTypes.ARRAY(DataType elementDataType) Data type of an array of elements with same subtype.
TableSchema.Builder	TableSchema.Builder.field(String name, DataType dataType) Add a field with name and data type.
static DataTypes.Field	DataTypes.FIELD(String name, DataType dataType) Field definition with field name and data type.
static DataTypes.Field	DataTypes.FIELD(String name, DataType dataType, String description) Field definition with field name, data type, and a description.
TableSchema.Builder	TableSchema.Builder.fields(String[] names, DataType[] dataTypes) Add an array of fields with names and data types.
static DataType	DataTypes.MAP(DataType keyDataType, DataType valueDataType) Data type of an associative array that maps keys (including NULL) to values (including NULL).
static DataType	DataTypes.MULTISET(DataType elementDataType) Data type of a multiset (=bag).

Uses of DataType in org.apache.flink.table.expressions

Methods in org.apache.flink.table.expressions that return DataType

Modifier and Type	Method and Description
DataType	CallExpression.getOutputDataType()
DataType	ValueLiteralExpression.getOutputDataType()
DataType	FieldReferenceExpression.getOutputDataType()
DataType	TypeLiteralExpression.getOutputDataType()
DataType	ResolvedExpression.getOutputDataType() Returns the data type of the computation result.

Constructors in org.apache.flink.table.expressions with parameters of type DataType

Constructor and Description
CallExpression(FunctionDefinition functionDefinition, List<ResolvedExpression> args, DataType dataType)
CallExpression(ObjectIdentifier objectIdentifier, FunctionDefinition functionDefinition, List<ResolvedExpression> args, DataType dataType)
FieldReferenceExpression(String name, DataType dataType, int inputIndex, int fieldIndex)
TypeLiteralExpression(DataType dataType)
ValueLiteralExpression(Object value, DataType dataType)

Uses of DataType in org.apache.flink.table.functions

Method parameters in org.apache.flink.table.functions with type arguments of type DataType

Modifier and Type	Method and Description
BuiltInFunctionDefinition.Builder	BuiltInFunctionDefinition.Builder.typedArguments(List<DataType> argumentTypes)

Uses of DataType in org.apache.flink.table.sinks

Methods in org.apache.flink.table.sinks that return DataType

Modifier and Type	Method and Description
default DataType	TableSink.getConsumedDataType() Returns the data type consumed by this TableSink.

Uses of DataType in org.apache.flink.table.sources

Methods in org.apache.flink.table.sources that return DataType

Modifier and Type	Method and Description
default DataType	TableSource.getProducedDataType() Returns the DataType for the produced data of the TableSource.

Uses of DataType in org.apache.flink.table.types

Subclasses of DataType in org.apache.flink.table.types

Modifier and Type	Class and Description
class	AtomicDataType A data type that does not contain further data types (e.g.
class	CollectionDataType A data type that contains an element type (e.g.
class	FieldsDataType A data type that contains field data types (e.g.
class	KeyValueDataType A data type that contains a key and value data type (e.g.

Methods in org.apache.flink.table.types that return DataType

Modifier and Type	Method and Description
DataType	CollectionDataType.bridgedTo(Class<?> newConversionClass)
DataType	AtomicDataType.bridgedTo(Class<?> newConversionClass)
abstract DataType	DataType.bridgedTo(Class<?> newConversionClass) Adds a hint that data should be represented using the given class when entering or leaving the table ecosystem.
DataType	FieldsDataType.bridgedTo(Class<?> newConversionClass)
DataType	KeyValueDataType.bridgedTo(Class<?> newConversionClass)
DataType	CollectionDataType.getElementDataType()
DataType	KeyValueDataType.getKeyDataType()
DataType	KeyValueDataType.getValueDataType()
DataType	CollectionDataType.notNull()
DataType	AtomicDataType.notNull()
abstract DataType	DataType.notNull() Adds a hint that null values are not expected in the data for this type.
DataType	FieldsDataType.notNull()
DataType	KeyValueDataType.notNull()
DataType	CollectionDataType.nullable()
DataType	AtomicDataType.nullable()
abstract DataType	DataType.nullable() Adds a hint that null values are expected in the data for this type (default behavior).
DataType	FieldsDataType.nullable()
DataType	KeyValueDataType.nullable()

Methods in org.apache.flink.table.types that return types with arguments of type DataType

Modifier and Type	Method and Description
Map<String,DataType>	FieldsDataType.getFieldDataTypes()

Constructors in org.apache.flink.table.types with parameters of type DataType

Constructor and Description
CollectionDataType(LogicalType logicalType, Class<?> conversionClass, DataType elementDataType)
CollectionDataType(LogicalType logicalType, DataType elementDataType)
KeyValueDataType(LogicalType logicalType, Class<?> conversionClass, DataType keyDataType, DataType valueDataType)
KeyValueDataType(LogicalType logicalType, DataType keyDataType, DataType valueDataType)

Constructor parameters in org.apache.flink.table.types with type arguments of type DataType

Constructor and Description
FieldsDataType(LogicalType logicalType, Class<?> conversionClass, Map<String,DataType> fieldDataTypes)
FieldsDataType(LogicalType logicalType, Map<String,DataType> fieldDataTypes)

Uses of DataType in org.apache.flink.table.types.inference

Methods in org.apache.flink.table.types.inference that return DataType

Modifier and Type	Method and Description
DataType	TypeInferenceUtil.Result.getOutputDataType()
DataType	TypeTransformation.transform(CallContext callContext, DataType typeToTransform) Transforms the given data type to a different data type under the given context.

Methods in org.apache.flink.table.types.inference that return types with arguments of type DataType

Modifier and Type	Method and Description
Optional<DataType>	TypeInferenceUtil.Result.getAccumulatorDataType()
List<DataType>	CallContext.getArgumentDataTypes() Returns a resolved list of the call's argument types.
Optional<List<DataType>>	TypeInference.getArgumentTypes()
List<DataType>	TypeInferenceUtil.Result.getExpectedArgumentTypes()
Optional<DataType>	TypeStrategy.inferType(CallContext callContext) Infers a type from the given function call.

Methods in org.apache.flink.table.types.inference with parameters of type DataType

Modifier and Type	Method and Description
DataType	TypeTransformation.transform(CallContext callContext, DataType typeToTransform) Transforms the given data type to a different data type under the given context.

Method parameters in org.apache.flink.table.types.inference with type arguments of type DataType

Modifier and Type	Method and Description
TypeInference.Builder	TypeInference.Builder.typedArguments(List<DataType> argumentTypes) Sets the list of argument types for specifying static input explicitly.

Constructors in org.apache.flink.table.types.inference with parameters of type DataType

Constructor and Description
Result(List<DataType> expectedArgumentTypes, DataType accumulatorDataType, DataType outputDataType)

Constructor parameters in org.apache.flink.table.types.inference with type arguments of type DataType

Constructor and Description
Result(List<DataType> expectedArgumentTypes, DataType accumulatorDataType, DataType outputDataType)

Uses of DataType in org.apache.flink.table.types.inference.strategies

Methods in org.apache.flink.table.types.inference.strategies that return types with arguments of type DataType

Modifier and Type	Method and Description
Optional<DataType>	MissingTypeStrategy.inferType(CallContext callContext)

Uses of DataType in org.apache.flink.table.types.utils

Methods in org.apache.flink.table.types.utils that return DataType

Modifier and Type	Method and Description
static DataType	TypeConversions.fromLegacyInfoToDataType(org.apache.flink.api.common.typeinfo.TypeInformation<?> typeInfo)
static DataType[]	TypeConversions.fromLegacyInfoToDataType(org.apache.flink.api.common.typeinfo.TypeInformation<?>[] typeInfo)
static DataType	TypeConversions.fromLogicalToDataType(LogicalType logicalType)
static DataType[]	TypeConversions.fromLogicalToDataType(LogicalType[] logicalTypes)
static DataType	DataTypeUtils.replaceLogicalType(DataType dataType, LogicalType replacement) Replaces the LogicalType of a DataType, i.e., it keeps the bridging class.
static DataType	LogicalTypeDataTypeConverter.toDataType(LogicalType logicalType) Returns the data type of a logical type without explicit conversions.
static DataType	LegacyTypeInfoDataTypeConverter.toDataType(org.apache.flink.api.common.typeinfo.TypeInformation<?> typeInfo)

Methods in org.apache.flink.table.types.utils that return types with arguments of type DataType

Modifier and Type	Method and Description
static Optional<DataType>	ClassDataTypeConverter.extractDataType(Class<?> clazz) Returns the clearly identifiable data type if possible.
static Optional<DataType>	ValueDataTypeConverter.extractDataType(Object value) Returns the clearly identifiable data type if possible.
static Optional<DataType>	TypeConversions.fromClassToDataType(Class<?> clazz)

Methods in org.apache.flink.table.types.utils with parameters of type DataType

Modifier and Type	Method and Description
protected abstract R	DataTypeDefaultVisitor.defaultMethod(DataType dataType)
static LogicalType	TypeConversions.fromDataToLogicalType(DataType dataType)
static LogicalType[]	TypeConversions.fromDataToLogicalType(DataType[] dataTypes)
static org.apache.flink.api.common.typeinfo.TypeInformation<?>	TypeConversions.fromDataTypeToLegacyInfo(DataType dataType)
static org.apache.flink.api.common.typeinfo.TypeInformation<?>[]	TypeConversions.fromDataTypeToLegacyInfo(DataType[] dataType)
static DataType	DataTypeUtils.replaceLogicalType(DataType dataType, LogicalType replacement) Replaces the LogicalType of a DataType, i.e., it keeps the bridging class.
static org.apache.flink.api.common.typeinfo.TypeInformation<?>	LegacyTypeInfoDataTypeConverter.toLegacyTypeInfo(DataType dataType)
static LogicalType	LogicalTypeDataTypeConverter.toLogicalType(DataType dataType) Returns the logical type of a data type.