Package org.apache.flink.api.common.operators

Class Keys.SelectorFunctionKeys<T,K>

java.lang.Object

org.apache.flink.api.common.operators.Keys<T>

org.apache.flink.api.common.operators.Keys.SelectorFunctionKeys<T,K>

Enclosing class:

Keys<T>

public static class Keys.SelectorFunctionKeys<T,K>
extends Keys<T>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.api.common.operators.Keys

Keys.ExpressionKeys<T>, Keys.IncompatibleKeysException, Keys.SelectorFunctionKeys<T,K>

Constructor Summary

Constructors

Constructor	Description
SelectorFunctionKeys(KeySelector<T,K> keyExtractor, TypeInformation<T> inputType, TypeInformation<K> keyType)

Method Summary

Modifier and Type	Method	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)

Methods inherited from class org.apache.flink.api.common.operators.Keys

areCompatible, isEmpty

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

SelectorFunctionKeys

public SelectorFunctionKeys(KeySelector<T,K> keyExtractor,
                            TypeInformation<T> inputType,
                            TypeInformation<K> keyType)

Method Detail

getKeyType

public TypeInformation<K> getKeyType()

getInputType

public TypeInformation<T> getInputType()

getKeyExtractor

public KeySelector<T,K> getKeyExtractor()

getNumberOfKeyFields

public int getNumberOfKeyFields()

Specified by:

getNumberOfKeyFields in class Keys<T>

computeLogicalKeyPositions

public int[] computeLogicalKeyPositions()

Specified by:

computeLogicalKeyPositions in class Keys<T>

getKeyFieldTypes

public TypeInformation<?>[] getKeyFieldTypes()

Specified by:

getKeyFieldTypes in class Keys<T>

getOriginalKeyFieldTypes

public TypeInformation<?>[] getOriginalKeyFieldTypes()

Specified by:

getOriginalKeyFieldTypes in class Keys<T>

validateCustomPartitioner

public <E> void validateCustomPartitioner(Partitioner<E> partitioner,
                                          TypeInformation<E> typeInfo)

Specified by:

validateCustomPartitioner in class Keys<T>

toString

public String toString()

Overrides:

toString in class Object