public class CRowTypeInfo extends CompositeType<CRow>
CompositeType.FlatFieldDescriptor, CompositeType.InvalidFieldReferenceException, CompositeType.TypeComparatorBuilder<T>
Constructor and Description |
---|
CRowTypeInfo(RowTypeInfo rowType) |
Modifier and Type | Method and Description |
---|---|
static CRowTypeInfo |
apply(TypeInformation<Row> rowType) |
boolean |
canEqual(Object obj)
Returns true if the given object can be equaled with this object.
|
TypeComparator<CRow> |
createComparator(int[] logicalKeyFields,
boolean[] orders,
int logicalFieldOffset,
ExecutionConfig config)
Generic implementation of the comparator creation.
|
TypeSerializer<CRow> |
createSerializer(ExecutionConfig config)
Creates a serializer for the type.
|
protected CompositeType.TypeComparatorBuilder<CRow> |
createTypeComparatorBuilder() |
boolean |
equals(Object obj) |
int |
getArity()
Gets the arity of this type - the number of fields without nesting.
|
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.
|
void |
getFlatFields(String fieldExpression,
int offset,
List<CompositeType.FlatFieldDescriptor> result)
Computes the flat field descriptors for the given field expression with the given offset.
|
static Map<String,TypeInformation<?>> |
getGenericParameters() |
int |
getTotalFields()
Gets the number of logical fields in this type.
|
<X> TypeInformation<X> |
getTypeAt(int pos)
Returns the type of the (unnested) field at the given field position.
|
<X> TypeInformation<X> |
getTypeAt(String fieldExpression)
Returns the type of the (nested) field at the given field expression position.
|
static Class<T> |
getTypeClass() |
static boolean |
hasDeterministicFieldOrder() |
static boolean |
hasField(String x$1) |
static int |
hashCode() |
boolean |
isBasicType()
Checks if this type information represents a basic type.
|
static boolean |
isKeyType() |
static boolean |
isSortKeyType() |
boolean |
isTupleType()
Checks if this type information represents a Tuple type.
|
RowTypeInfo |
rowType() |
static String |
toString() |
getFlatFields, getTypeClass, hasDeterministicFieldOrder, hasField, hashCode, isKeyType, isSortKeyType, toString
getGenericParameters, of, of
public CRowTypeInfo(RowTypeInfo rowType)
public static CRowTypeInfo apply(TypeInformation<Row> rowType)
public static Map<String,TypeInformation<?>> getGenericParameters()
public static Class<T> getTypeClass()
public static boolean hasField(String x$1)
public static boolean isKeyType()
public static boolean isSortKeyType()
public static boolean hasDeterministicFieldOrder()
public static int hashCode()
public static String toString()
public RowTypeInfo rowType()
public String[] getFieldNames()
CompositeType
getFieldNames
in class CompositeType<CRow>
public int getFieldIndex(String fieldName)
CompositeType
getFieldIndex
in class CompositeType<CRow>
public <X> TypeInformation<X> getTypeAt(String fieldExpression)
CompositeType
getTypeAt
in class CompositeType<CRow>
fieldExpression
- The field expression for which the field of which the type is returned.public <X> TypeInformation<X> getTypeAt(int pos)
CompositeType
getTypeAt
in class CompositeType<CRow>
pos
- The position of the (unnested) field in this composite type.public void getFlatFields(String fieldExpression, int offset, List<CompositeType.FlatFieldDescriptor> result)
CompositeType
getFlatFields
in class CompositeType<CRow>
fieldExpression
- The field expression for which the FlatFieldDescriptors are computed.offset
- The offset to use when computing the positions of the flat fields.result
- The list into which all flat field descriptors are inserted.public boolean isBasicType()
TypeInformation
BasicTypeInfo
and are primitives, their boxing types,
Strings, Date, Void, ...isBasicType
in class TypeInformation<CRow>
public boolean isTupleType()
TypeInformation
isTupleType
in class TypeInformation<CRow>
public int getArity()
TypeInformation
getArity
in class TypeInformation<CRow>
public int getTotalFields()
TypeInformation
getTotalFields
in class TypeInformation<CRow>
public TypeSerializer<CRow> createSerializer(ExecutionConfig config)
TypeInformation
createSerializer
in class TypeInformation<CRow>
config
- The config used to parameterize the serializer.protected CompositeType.TypeComparatorBuilder<CRow> createTypeComparatorBuilder()
createTypeComparatorBuilder
in class CompositeType<CRow>
public TypeComparator<CRow> createComparator(int[] logicalKeyFields, boolean[] orders, int logicalFieldOffset, ExecutionConfig config)
CompositeType
createComparator
in class CompositeType<CRow>
public boolean equals(Object obj)
equals
in class CompositeType<CRow>
public boolean canEqual(Object obj)
TypeInformation
canEqual
in class CompositeType<CRow>
obj
- Object which wants to take part in the equality relationCopyright © 2014–2018 The Apache Software Foundation. All rights reserved.