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

Packages that use Keys.SelectorFunctionKeys

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

Uses of Keys.SelectorFunctionKeys in org.apache.flink.api.java.operators

Methods in org.apache.flink.api.java.operators that return Keys.SelectorFunctionKeys

Modifier and Type	Method and Description
protected Keys.SelectorFunctionKeys<T,?>	SortedGrouping.getSortSelectionFunctionKey() Deprecated.

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

Modifier and Type	Method and Description
static <T,K> Operator<Tuple2<K,T>>	KeyFunctions.appendKeyExtractor(Operator<T> input, Keys.SelectorFunctionKeys<T,K> key)
static <T,K1,K2> Operator<Tuple3<K1,K2,T>>	KeyFunctions.appendKeyExtractor(Operator<T> input, Keys.SelectorFunctionKeys<T,K1> key1, Keys.SelectorFunctionKeys<T,K2> key2)
static <T,K1,K2> Operator<Tuple3<K1,K2,T>>	KeyFunctions.appendKeyExtractor(Operator<T> input, Keys.SelectorFunctionKeys<T,K1> key1, Keys.SelectorFunctionKeys<T,K2> key2)
static <T,K> SingleInputOperator<?,T,?>	KeyFunctions.appendKeyRemover(Operator<Tuple2<K,T>> inputWithKey, Keys.SelectorFunctionKeys<T,K> key)
static <T,K> TypeInformation<Tuple2<K,T>>	KeyFunctions.createTypeWithKey(Keys.SelectorFunctionKeys<T,K> key)
static <T,K1,K2> TypeInformation<Tuple3<K1,K2,T>>	KeyFunctions.createTypeWithKey(Keys.SelectorFunctionKeys<T,K1> key1, Keys.SelectorFunctionKeys<T,K2> key2)
static <T,K1,K2> TypeInformation<Tuple3<K1,K2,T>>	KeyFunctions.createTypeWithKey(Keys.SelectorFunctionKeys<T,K1> key1, Keys.SelectorFunctionKeys<T,K2> key2)

Constructors in org.apache.flink.api.java.operators with parameters of type Keys.SelectorFunctionKeys

Constructor and Description
SortedGrouping(DataSet<T> set, Keys<T> keys, Keys.SelectorFunctionKeys<T,K> keySelector, Order order) Deprecated.
SortPartitionOperator(DataSet<T> dataSet, Keys.SelectorFunctionKeys<T,K> sortKey, Order sortOrder, String sortLocationName) Deprecated.

Uses of Keys.SelectorFunctionKeys in org.apache.flink.api.java.operators.translation

Constructors in org.apache.flink.api.java.operators.translation with parameters of type Keys.SelectorFunctionKeys

Constructor and Description
PlanBothUnwrappingCoGroupOperator(CoGroupFunction<I1,I2,OUT> udf, Keys.SelectorFunctionKeys<I1,K> key1, Keys.SelectorFunctionKeys<I2,K> key2, String name, TypeInformation<OUT> type, TypeInformation<Tuple2<K,I1>> typeInfoWithKey1, TypeInformation<Tuple2<K,I2>> typeInfoWithKey2)
PlanBothUnwrappingCoGroupOperator(CoGroupFunction<I1,I2,OUT> udf, Keys.SelectorFunctionKeys<I1,K> key1, Keys.SelectorFunctionKeys<I2,K> key2, String name, TypeInformation<OUT> type, TypeInformation<Tuple2<K,I1>> typeInfoWithKey1, TypeInformation<Tuple2<K,I2>> typeInfoWithKey2)
PlanLeftUnwrappingCoGroupOperator(CoGroupFunction<I1,I2,OUT> udf, Keys.SelectorFunctionKeys<I1,K> key1, int[] key2, String name, TypeInformation<OUT> resultType, TypeInformation<Tuple2<K,I1>> typeInfoWithKey1, TypeInformation<I2> typeInfo2)
PlanRightUnwrappingCoGroupOperator(CoGroupFunction<I1,I2,OUT> udf, int[] key1, Keys.SelectorFunctionKeys<I2,K> key2, String name, TypeInformation<OUT> resultType, TypeInformation<I1> typeInfo1, TypeInformation<Tuple2<K,I2>> typeInfoWithKey2)
PlanUnwrappingGroupCombineOperator(GroupCombineFunction<IN,OUT> udf, Keys.SelectorFunctionKeys<IN,K> key, String name, TypeInformation<OUT> outType, TypeInformation<Tuple2<K,IN>> typeInfoWithKey)
PlanUnwrappingReduceGroupOperator(GroupReduceFunction<IN,OUT> udf, Keys.SelectorFunctionKeys<IN,K> key, String name, TypeInformation<OUT> outType, TypeInformation<Tuple2<K,IN>> typeInfoWithKey, boolean combinable)
PlanUnwrappingReduceOperator(ReduceFunction<T> udf, Keys.SelectorFunctionKeys<T,K> key, String name, TypeInformation<T> type, TypeInformation<Tuple2<K,T>> typeInfoWithKey)
PlanUnwrappingSortedGroupCombineOperator(GroupCombineFunction<IN,OUT> udf, Keys.SelectorFunctionKeys<IN,K1> groupingKey, Keys.SelectorFunctionKeys<IN,K2> sortingKey, String name, TypeInformation<OUT> outType, TypeInformation<Tuple3<K1,K2,IN>> typeInfoWithKey)
PlanUnwrappingSortedGroupCombineOperator(GroupCombineFunction<IN,OUT> udf, Keys.SelectorFunctionKeys<IN,K1> groupingKey, Keys.SelectorFunctionKeys<IN,K2> sortingKey, String name, TypeInformation<OUT> outType, TypeInformation<Tuple3<K1,K2,IN>> typeInfoWithKey)
PlanUnwrappingSortedReduceGroupOperator(GroupReduceFunction<IN,OUT> udf, Keys.SelectorFunctionKeys<IN,K1> groupingKey, Keys.SelectorFunctionKeys<IN,K2> sortingKey, String name, TypeInformation<OUT> outType, TypeInformation<Tuple3<K1,K2,IN>> typeInfoWithKey, boolean combinable)
PlanUnwrappingSortedReduceGroupOperator(GroupReduceFunction<IN,OUT> udf, Keys.SelectorFunctionKeys<IN,K1> groupingKey, Keys.SelectorFunctionKeys<IN,K2> sortingKey, String name, TypeInformation<OUT> outType, TypeInformation<Tuple3<K1,K2,IN>> typeInfoWithKey, boolean combinable)