Uses of Class
org.apache.flink.api.common.operators.Keys

Packages that use Keys

Package	Description
org.apache.flink.api.common.operators
org.apache.flink.streaming.api.datastream
org.apache.flink.streaming.util.keys

Uses of Keys in org.apache.flink.api.common.operators

Subclasses of Keys in org.apache.flink.api.common.operators

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

Methods in org.apache.flink.api.common.operators with parameters of type Keys

Modifier and Type	Method	Description
boolean	Keys.areCompatible(Keys<?> other)	Check if two sets of keys are compatible to each other (matching types, key counts)

Uses of Keys in org.apache.flink.streaming.api.datastream

Methods in org.apache.flink.streaming.api.datastream with parameters of type Keys

Modifier and Type	Method	Description
protected KeyedStream<T,Tuple>	DataStream.keyBy(Keys<T> keys)

Uses of Keys in org.apache.flink.streaming.util.keys

Methods in org.apache.flink.streaming.util.keys with parameters of type Keys

Modifier and Type	Method	Description
static <X> KeySelector<X,Tuple>	KeySelectorUtil.getSelectorForKeys(Keys<X> keys, TypeInformation<X> typeInfo, ExecutionConfig executionConfig)
static <X,K> KeySelector<X,K>	KeySelectorUtil.getSelectorForOneKey(Keys<X> keys, Partitioner<K> partitioner, TypeInformation<X> typeInfo, ExecutionConfig executionConfig)