org.apache.flink.table.runtime.typeutils

Class BaseRowTypeInfo

java.lang.Object

org.apache.flink.api.common.typeinfo.TypeInformation<T>

org.apache.flink.api.common.typeutils.CompositeType<T>

org.apache.flink.api.java.typeutils.TupleTypeInfoBase<BaseRow>

org.apache.flink.table.runtime.typeutils.BaseRowTypeInfo

All Implemented Interfaces:

Serializable

public class BaseRowTypeInfo
extends TupleTypeInfoBase<BaseRow>

Base row type info.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.api.common.typeutils.CompositeType

CompositeType.FlatFieldDescriptor, CompositeType.InvalidFieldReferenceException, CompositeType.TypeComparatorBuilder<T>

Field Summary

Fields inherited from class org.apache.flink.api.java.typeutils.TupleTypeInfoBase

types

Constructor Summary

Constructors

Constructor and Description
BaseRowTypeInfo(LogicalType... logicalTypes)
BaseRowTypeInfo(LogicalType[] logicalTypes, String[] fieldNames)

Method Summary

Modifier and Type	Method and Description
boolean	canEqual(Object obj) Returns true if the given object can be equaled with this object.
TypeComparator<BaseRow>	createComparator(int[] logicalKeyFields, boolean[] orders, int logicalFieldOffset, ExecutionConfig config) Generic implementation of the comparator creation.
BaseRowSerializer	createSerializer(ExecutionConfig config) Creates a serializer for the type.
CompositeType.TypeComparatorBuilder<BaseRow>	createTypeComparatorBuilder()
static String[]	generateDefaultFieldNames(int length)
int	getFieldIndex(String fieldName) Returns the field index of the composite field of the given name.
String[]	getFieldNames() Returns the names of the composite fields of this type.
TypeInformation<?>[]	getFieldTypes() Returns the field types of the row.
LogicalType[]	getLogicalTypes()
<X> TypeInformation<X>	getTypeAt(String fieldExpression) Returns the type of the (nested) field at the given field expression position.
int	hashCode()
static BaseRowTypeInfo	of(RowType rowType)
RowType	toRowType()
String	toString()

Methods inherited from class org.apache.flink.api.java.typeutils.TupleTypeInfoBase

equals, getArity, getFlatFields, getTotalFields, getTypeAt, hasDeterministicFieldOrder, isBasicType, isCaseClass, isTupleType

Methods inherited from class org.apache.flink.api.common.typeutils.CompositeType

getFlatFields, getTypeClass, hasField, isKeyType, isSortKeyType

Methods inherited from class org.apache.flink.api.common.typeinfo.TypeInformation

getGenericParameters, of, of

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

BaseRowTypeInfo

public BaseRowTypeInfo(LogicalType... logicalTypes)

BaseRowTypeInfo

public BaseRowTypeInfo(LogicalType[] logicalTypes,
                       String[] fieldNames)

Method Detail

generateDefaultFieldNames

public static String[] generateDefaultFieldNames(int length)

getTypeAt

public <X> TypeInformation<X> getTypeAt(String fieldExpression)

Description copied from class: CompositeType

Returns the type of the (nested) field at the given field expression position. Wildcards are not allowed.

Overrides:

getTypeAt in class TupleTypeInfoBase<BaseRow>

Parameters:

fieldExpression - The field expression for which the field of which the type is returned.

Returns:

The type of the field at the given field expression.

createComparator

public TypeComparator<BaseRow> createComparator(int[] logicalKeyFields,
                                                boolean[] orders,
                                                int logicalFieldOffset,
                                                ExecutionConfig config)

Description copied from class: CompositeType

Generic implementation of the comparator creation. Composite types are supplying the infrastructure to create the actual comparators

Overrides:

createComparator in class CompositeType<BaseRow>

Returns:

The comparator

getFieldNames

public String[] getFieldNames()

Description copied from class: CompositeType

Returns the names of the composite fields of this type. The order of the returned array must be consistent with the internal field index ordering.

Specified by:

getFieldNames in class CompositeType<BaseRow>

getFieldIndex

public int getFieldIndex(String fieldName)

Description copied from class: CompositeType

Returns the field index of the composite field of the given name.

Specified by:

getFieldIndex in class CompositeType<BaseRow>

Returns:

The field index or -1 if this type does not have a field of the given name.

canEqual

public boolean canEqual(Object obj)

Description copied from class: TypeInformation

Returns true if the given object can be equaled with this object. If not, it returns false.

Overrides:

canEqual in class TupleTypeInfoBase<BaseRow>

Parameters:

obj - Object which wants to take part in the equality relation

Returns:

true if obj can be equaled with this, otherwise false

hashCode

public int hashCode()

Overrides:

hashCode in class TupleTypeInfoBase<BaseRow>

toString

public String toString()

Overrides:

toString in class TupleTypeInfoBase<BaseRow>

getFieldTypes

public TypeInformation<?>[] getFieldTypes()

Returns the field types of the row. The order matches the order of the field names.

createTypeComparatorBuilder

public CompositeType.TypeComparatorBuilder<BaseRow> createTypeComparatorBuilder()

Specified by:

createTypeComparatorBuilder in class CompositeType<BaseRow>

createSerializer

public BaseRowSerializer createSerializer(ExecutionConfig config)

Description copied from class: TypeInformation

Creates a serializer for the type. The serializer may use the ExecutionConfig for parameterization.

Specified by:

createSerializer in class TypeInformation<BaseRow>

Parameters:

config - The config used to parameterize the serializer.

Returns:

A serializer for this type.

getLogicalTypes

public LogicalType[] getLogicalTypes()

toRowType

public RowType toRowType()

of

public static BaseRowTypeInfo of(RowType rowType)