@Internal public class RowDataTypeInfo extends TupleTypeInfoBase<RowData>
RowData
.CompositeType.FlatFieldDescriptor, CompositeType.InvalidFieldReferenceException, CompositeType.TypeComparatorBuilder<T>
types
Constructor and Description |
---|
RowDataTypeInfo(LogicalType... logicalTypes) |
RowDataTypeInfo(LogicalType[] logicalTypes,
String[] fieldNames) |
RowDataTypeInfo(RowType rowType) |
Modifier and Type | Method and Description |
---|---|
boolean |
canEqual(Object obj)
Returns true if the given object can be equaled with this object.
|
TypeComparator<RowData> |
createComparator(int[] logicalKeyFields,
boolean[] orders,
int logicalFieldOffset,
ExecutionConfig config)
Generic implementation of the comparator creation.
|
RowDataSerializer |
createSerializer(ExecutionConfig config)
Creates a serializer for the type.
|
CompositeType.TypeComparatorBuilder<RowData> |
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 RowDataTypeInfo |
of(RowType rowType) |
RowType |
toRowType() |
String |
toString() |
equals, getArity, getFlatFields, getTotalFields, getTypeAt, hasDeterministicFieldOrder, isBasicType, isCaseClass, isTupleType
getFlatFields, getTypeClass, hasField, isKeyType, isSortKeyType
getGenericParameters, of, of
public RowDataTypeInfo(RowType rowType)
public RowDataTypeInfo(LogicalType... logicalTypes)
public RowDataTypeInfo(LogicalType[] logicalTypes, String[] fieldNames)
public static String[] generateDefaultFieldNames(int length)
public <X> TypeInformation<X> getTypeAt(String fieldExpression)
CompositeType
getTypeAt
in class TupleTypeInfoBase<RowData>
fieldExpression
- The field expression for which the field of which the type is
returned.public TypeComparator<RowData> createComparator(int[] logicalKeyFields, boolean[] orders, int logicalFieldOffset, ExecutionConfig config)
CompositeType
createComparator
in class CompositeType<RowData>
public String[] getFieldNames()
CompositeType
getFieldNames
in class CompositeType<RowData>
public int getFieldIndex(String fieldName)
CompositeType
getFieldIndex
in class CompositeType<RowData>
public boolean canEqual(Object obj)
TypeInformation
canEqual
in class TupleTypeInfoBase<RowData>
obj
- Object which wants to take part in the equality relationpublic int hashCode()
hashCode
in class TupleTypeInfoBase<RowData>
public String toString()
toString
in class TupleTypeInfoBase<RowData>
public TypeInformation<?>[] getFieldTypes()
public CompositeType.TypeComparatorBuilder<RowData> createTypeComparatorBuilder()
createTypeComparatorBuilder
in class CompositeType<RowData>
public RowDataSerializer createSerializer(ExecutionConfig config)
TypeInformation
createSerializer
in class TypeInformation<RowData>
config
- The config used to parameterize the serializer.public LogicalType[] getLogicalTypes()
public RowType toRowType()
public static RowDataTypeInfo of(RowType rowType)
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.