Keys.ExpressionKeys<T>, Keys.IncompatibleKeysException, Keys.SelectorFunctionKeys<T,K>
Constructor and Description |
---|
SelectorFunctionKeys(KeySelector<T,K> keyExtractor,
TypeInformation<T> inputType,
TypeInformation<K> keyType) |
Modifier and Type | Method and Description |
---|---|
int[] |
computeLogicalKeyPositions() |
TypeInformation<T> |
getInputType() |
KeySelector<T,K> |
getKeyExtractor() |
TypeInformation<?>[] |
getKeyFieldTypes() |
TypeInformation<K> |
getKeyType() |
int |
getNumberOfKeyFields() |
TypeInformation<?>[] |
getOriginalKeyFieldTypes() |
String |
toString() |
<E> void |
validateCustomPartitioner(Partitioner<E> partitioner,
TypeInformation<E> typeInfo) |
areCompatible, isEmpty
public SelectorFunctionKeys(KeySelector<T,K> keyExtractor, TypeInformation<T> inputType, TypeInformation<K> keyType)
public TypeInformation<K> getKeyType()
public TypeInformation<T> getInputType()
public KeySelector<T,K> getKeyExtractor()
public int getNumberOfKeyFields()
getNumberOfKeyFields
in class Keys<T>
public int[] computeLogicalKeyPositions()
computeLogicalKeyPositions
in class Keys<T>
public TypeInformation<?>[] getKeyFieldTypes()
getKeyFieldTypes
in class Keys<T>
public TypeInformation<?>[] getOriginalKeyFieldTypes()
getOriginalKeyFieldTypes
in class Keys<T>
public <E> void validateCustomPartitioner(Partitioner<E> partitioner, TypeInformation<E> typeInfo)
validateCustomPartitioner
in class Keys<T>
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.