Package org.apache.wayang.flink.compiler

Class KeySelectorDistinct<T>

java.lang.Object

org.apache.wayang.flink.compiler.KeySelectorDistinct<T>

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.java.functions.KeySelector<T,String>

public class KeySelectorDistinct<T>
extends Object
implements org.apache.flink.api.java.functions.KeySelector<T,String>, Serializable

Wrapper for

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
KeySelectorDistinct()

Method Summary

Modifier and Type	Method	Description
String	getKey(T value)

Methods inherited from class java.lang.Object

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

Constructor Details

KeySelectorDistinct

public KeySelectorDistinct()

Method Details

getKey

public String getKey(T value)

Specified by:

getKey in interface org.apache.flink.api.java.functions.KeySelector<T,String>