Package org.apache.wayang.flink.compiler
Class KeySelectorDistinct<T>
- java.lang.Object
-
- org.apache.wayang.flink.compiler.KeySelectorDistinct<T>
-
- All Implemented Interfaces:
java.io.Serializable
,org.apache.flink.api.common.functions.Function
,org.apache.flink.api.java.functions.KeySelector<T,java.lang.String>
public class KeySelectorDistinct<T> extends java.lang.Object implements org.apache.flink.api.java.functions.KeySelector<T,java.lang.String>, java.io.Serializable
Wrapper forKeySelector
- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description KeySelectorDistinct()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.String
getKey(T value)
-