public class RowTypeInfo extends CaseClassTypeInfo<Row>
Row
.CompositeType.FlatFieldDescriptor, CompositeType.InvalidFieldReferenceException, CompositeType.TypeComparatorBuilder<T>
types
Constructor and Description |
---|
RowTypeInfo(scala.collection.Seq<TypeInformation<?>> fieldTypes) |
RowTypeInfo(TypeInformation<?>[] fieldTypes) |
Modifier and Type | Method and Description |
---|---|
scala.Option<boolean[]> |
comparatorOrders()
Temporary variable for directly passing orders to comparators.
|
TypeComparator<Row> |
createComparator(int[] logicalKeyFields,
boolean[] orders,
int logicalFieldOffset,
ExecutionConfig config)
Generic implementation of the comparator creation.
|
TypeSerializer<Row> |
createSerializer(ExecutionConfig executionConfig)
Creates a serializer for the type.
|
CompositeType.TypeComparatorBuilder<Row> |
createTypeComparatorBuilder() |
canEqual, equals, fieldNames, getFieldIndex, getFieldIndices, getFieldNames, getFlatFields, getGenericParameters, getTypeAt, hashCode, isCaseClass, toString, typeParamTypeInfos
getArity, getTotalFields, getTypeAt, hasDeterministicFieldOrder, isBasicType, isTupleType
getFlatFields, getTypeClass, hasField, isKeyType, isSortKeyType
of, of
public RowTypeInfo(scala.collection.Seq<TypeInformation<?>> fieldTypes)
public RowTypeInfo(TypeInformation<?>[] fieldTypes)
public scala.Option<boolean[]> comparatorOrders()
public TypeSerializer<Row> createSerializer(ExecutionConfig executionConfig)
TypeInformation
createSerializer
in class TypeInformation<Row>
executionConfig
- The config used to parameterize the serializer.public TypeComparator<Row> createComparator(int[] logicalKeyFields, boolean[] orders, int logicalFieldOffset, ExecutionConfig config)
CompositeType
createComparator
in class CompositeType<Row>
public CompositeType.TypeComparatorBuilder<Row> createTypeComparatorBuilder()
createTypeComparatorBuilder
in class CaseClassTypeInfo<Row>
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.