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

Class Keys<T>

java.lang.Object

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

Direct Known Subclasses:

Keys.ExpressionKeys, Keys.SelectorFunctionKeys

@Internal
public abstract class Keys<T>
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	Keys.ExpressionKeys<T>	Represents (nested) field access through string and integer-based keys
static class	Keys.IncompatibleKeysException
static class	Keys.SelectorFunctionKeys<T,K>

Constructor Summary

Constructors

Constructor	Description
Keys()

Method Summary

Modifier and Type	Method	Description
boolean	areCompatible(Keys<?> other)	Check if two sets of keys are compatible to each other (matching types, key counts)
abstract int[]	computeLogicalKeyPositions()
abstract TypeInformation<?>[]	getKeyFieldTypes()
abstract int	getNumberOfKeyFields()
abstract TypeInformation<?>[]	getOriginalKeyFieldTypes()
boolean	isEmpty()
abstract <E> void	validateCustomPartitioner(Partitioner<E> partitioner, TypeInformation<E> typeInfo)

Methods inherited from class java.lang.Object

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

Constructor Detail

Keys

public Keys()

Method Detail

getNumberOfKeyFields

public abstract int getNumberOfKeyFields()

computeLogicalKeyPositions

public abstract int[] computeLogicalKeyPositions()

getKeyFieldTypes

public abstract TypeInformation<?>[] getKeyFieldTypes()

getOriginalKeyFieldTypes

public abstract TypeInformation<?>[] getOriginalKeyFieldTypes()

validateCustomPartitioner

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

isEmpty

public boolean isEmpty()

areCompatible

public boolean areCompatible(Keys<?> other)
                      throws Keys.IncompatibleKeysException

Check if two sets of keys are compatible to each other (matching types, key counts)

Throws:

Keys.IncompatibleKeysException