KeySelectorFunction (Apache Wayang (incubating) 0.7.1 API)

java.lang.Object
- org.apache.wayang.flink.compiler.KeySelectorFunction<T,K>

All Implemented Interfaces:

java.io.Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.java.functions.KeySelector<T,K>, org.apache.flink.api.java.typeutils.ResultTypeQueryable<K>
```
public class KeySelectorFunction<T,K>
extends java.lang.Object
implements org.apache.flink.api.java.functions.KeySelector<T,K>, org.apache.flink.api.java.typeutils.ResultTypeQueryable<K>, java.io.Serializable
```
Wrapper for KeySelector

See Also:

Serialized Form

- Field Summary
  
  Fields
  Modifier and Type Field Description
  
  java.util.function.Function<T,K> impl
  
  java.lang.Class<K> key
  
  org.apache.flink.api.common.typeinfo.TypeInformation<K> typeInformation
- Constructor Summary
  
  Constructors
  Constructor Description
  
  KeySelectorFunction(TransformationDescriptor<T,K> transformationDescriptor)
- Method Summary
  
  All Methods Instance Methods Concrete Methods
  Modifier and Type Method Description
  
  K getKey(T object)
  
  org.apache.flink.api.common.typeinfo.TypeInformation getProducedType()
  - Methods inherited from class java.lang.Object
    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

impl

public java.util.function.Function<T,K> impl

key
```
public java.lang.Class<K> key
```

typeInformation

public org.apache.flink.api.common.typeinfo.TypeInformation<K> typeInformation

Constructor Detail

KeySelectorFunction

public KeySelectorFunction(TransformationDescriptor<T,K> transformationDescriptor)

Method Detail
- getKey
```
public K getKey(T object)
```
  Specified by:
  
  getKey in interface org.apache.flink.api.java.functions.KeySelector<T,K>
- getProducedType
```
public org.apache.flink.api.common.typeinfo.TypeInformation getProducedType()
```
  Specified by:
  
  getProducedType in interface org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>