org.apache.flink.streaming.util.keys

Class KeySelectorUtil

java.lang.Object

org.apache.flink.streaming.util.keys.KeySelectorUtil

@Internal
public final class KeySelectorUtil
extends Object

Utility class that contains helper methods to manipulating KeySelector for streaming.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	KeySelectorUtil.ArrayKeySelector<IN> A key selector for selecting individual array fields as keys and returns them as a Tuple.
static class	KeySelectorUtil.ComparableKeySelector<IN> A key selector for selecting key fields via a TypeComparator.
static class	KeySelectorUtil.OneKeySelector<IN,K> Key extractor that extracts a single field via a generic comparator.

Method Summary

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

Methods inherited from class java.lang.Object

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

Method Detail

getSelectorForKeys

public static <X> KeySelector<X,Tuple> getSelectorForKeys(Keys<X> keys,
                                                          TypeInformation<X> typeInfo,
                                                          ExecutionConfig executionConfig)

getSelectorForArray

public static <X> KeySelectorUtil.ArrayKeySelector<X> getSelectorForArray(int[] positions,
                                                                          TypeInformation<X> typeInfo)

getSelectorForOneKey

public static <X,K> KeySelector<X,K> getSelectorForOneKey(Keys<X> keys,
                                                          Partitioner<K> partitioner,
                                                          TypeInformation<X> typeInfo,
                                                          ExecutionConfig executionConfig)