Package org.apache.flink.api.java.operators

Class KeyFunctions

java.lang.Object

org.apache.flink.api.java.operators.KeyFunctions

@Internal
public class KeyFunctions
extends Object

This class holds static utilities to append functions that extract and prune keys.

Constructor Summary

Constructors

Constructor	Description
KeyFunctions()

Method Summary

Modifier and Type	Method	Description
static <T,K> org.apache.flink.api.common.operators.Operator<org.apache.flink.api.java.tuple.Tuple2<K,T>>	appendKeyExtractor(org.apache.flink.api.common.operators.Operator<T> input, org.apache.flink.api.common.operators.Keys.SelectorFunctionKeys<T,K> key)
static <T,K1,K2> org.apache.flink.api.common.operators.Operator<org.apache.flink.api.java.tuple.Tuple3<K1,K2,T>>	appendKeyExtractor(org.apache.flink.api.common.operators.Operator<T> input, org.apache.flink.api.common.operators.Keys.SelectorFunctionKeys<T,K1> key1, org.apache.flink.api.common.operators.Keys.SelectorFunctionKeys<T,K2> key2)
static <T,K> org.apache.flink.api.common.operators.SingleInputOperator<?,T,?>	appendKeyRemover(org.apache.flink.api.common.operators.Operator<org.apache.flink.api.java.tuple.Tuple2<K,T>> inputWithKey, org.apache.flink.api.common.operators.Keys.SelectorFunctionKeys<T,K> key)
static <T,K> org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.api.java.tuple.Tuple2<K,T>>	createTypeWithKey(org.apache.flink.api.common.operators.Keys.SelectorFunctionKeys<T,K> key)
static <T,K1,K2> org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.api.java.tuple.Tuple3<K1,K2,T>>	createTypeWithKey(org.apache.flink.api.common.operators.Keys.SelectorFunctionKeys<T,K1> key1, org.apache.flink.api.common.operators.Keys.SelectorFunctionKeys<T,K2> key2)

Methods inherited from class java.lang.Object

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

Constructor Detail

KeyFunctions

public KeyFunctions()

Method Detail

appendKeyExtractor

public static <T,K> org.apache.flink.api.common.operators.Operator<org.apache.flink.api.java.tuple.Tuple2<K,T>> appendKeyExtractor(org.apache.flink.api.common.operators.Operator<T> input,
                                                                                                                                               org.apache.flink.api.common.operators.Keys.SelectorFunctionKeys<T,K> key)

appendKeyExtractor

public static <T,K1,K2> org.apache.flink.api.common.operators.Operator<org.apache.flink.api.java.tuple.Tuple3<K1,K2,T>> appendKeyExtractor(org.apache.flink.api.common.operators.Operator<T> input,
                                                                                                                                                                   org.apache.flink.api.common.operators.Keys.SelectorFunctionKeys<T,K1> key1,
                                                                                                                                                                   org.apache.flink.api.common.operators.Keys.SelectorFunctionKeys<T,K2> key2)

appendKeyRemover

public static <T,K> org.apache.flink.api.common.operators.SingleInputOperator<?,T,?> appendKeyRemover(org.apache.flink.api.common.operators.Operator<org.apache.flink.api.java.tuple.Tuple2<K,T>> inputWithKey,
                                                                                                                        org.apache.flink.api.common.operators.Keys.SelectorFunctionKeys<T,K> key)

createTypeWithKey

public static <T,K> org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.api.java.tuple.Tuple2<K,T>> createTypeWithKey(org.apache.flink.api.common.operators.Keys.SelectorFunctionKeys<T,K> key)

createTypeWithKey

public static <T,K1,K2> org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.api.java.tuple.Tuple3<K1,K2,T>> createTypeWithKey(org.apache.flink.api.common.operators.Keys.SelectorFunctionKeys<T,K1> key1,
                                                                                                                                                                        org.apache.flink.api.common.operators.Keys.SelectorFunctionKeys<T,K2> key2)