org.apache.flink.table.catalog

Interface DataTypeFactory

@PublicEvolving
public interface DataTypeFactory

Factory for creating fully resolved data types that can be used for planning.

The factory is useful for types that cannot be created with one of the static methods in DataTypes) because they require access to configuration or catalog.

Method Summary

Modifier and Type	Method and Description
DataType	createDataType(AbstractDataType<?> abstractDataType) Creates a type out of an AbstractDataType.
<T> DataType	createDataType(Class<T> clazz) Creates a type by analyzing the given class.
DataType	createDataType(String name) Creates a type by a fully or partially defined name.
DataType	createDataType(UnresolvedIdentifier identifier) Creates a type by a fully or partially defined identifier.
<T> DataType	createRawDataType(Class<T> clazz) Creates a RAW type for the given class in cases where no serializer is known and a generic serializer should be used.

Method Detail

createDataType

DataType createDataType(AbstractDataType<?> abstractDataType)

Creates a type out of an AbstractDataType.

If the given type is already a DataType, the factory will return it unmodified. In case of UnresolvedDataType, the factory will resolve it to a DataType.

createDataType

DataType createDataType(String name)

Creates a type by a fully or partially defined name.

The factory will parse and resolve the name of a type to a DataType. This includes both built-in types as well as user-defined types (see DistinctType and StructuredType).

createDataType

DataType createDataType(UnresolvedIdentifier identifier)

Creates a type by a fully or partially defined identifier.

The factory will parse and resolve the name of a type to a DataType. This includes both built-in types as well as user-defined types (see DistinctType and StructuredType).

createDataType

<T> DataType createDataType(Class<T> clazz)

Creates a type by analyzing the given class.

It does this by using Java reflection which can be supported by DataTypeHint annotations for nested, structured types.

It will throw an ValidationException in cases where the reflective extraction needs more information or simply fails.

See DataTypes.of(Class) for further examples.

createRawDataType

<T> DataType createRawDataType(Class<T> clazz)

Creates a RAW type for the given class in cases where no serializer is known and a generic serializer should be used. The factory will create DataTypes.RAW(Class, TypeSerializer) with Flink's default RAW serializer that is automatically configured.

Note: This type is a black box within the table ecosystem and is only deserialized at the edges of the API.