FunctionCompiler.KeyExtractor (Apache Wayang (incubating) 0.7.1 API)

java.lang.Object
- org.apache.wayang.spark.compiler.FunctionCompiler.KeyExtractor<T,K>

All Implemented Interfaces:

java.io.Serializable, org.apache.spark.api.java.function.PairFunction<T,K,T>, FunctionCompiler.WayangSparkFunction

Enclosing class:

FunctionCompiler
```
public static class FunctionCompiler.KeyExtractor<T,K>
extends java.lang.Object
implements org.apache.spark.api.java.function.PairFunction<T,K,T>, FunctionCompiler.WayangSparkFunction
```
Spark function for building pair RDDs.

See Also:

Serialized Form

- Constructor Summary
  
  Constructors
  Constructor Description
  
  KeyExtractor(java.util.function.Function<T,K> impl)
- Method Summary
  
  All Methods Instance Methods Concrete Methods
  Modifier and Type Method Description
  
  scala.Tuple2<K,T> call(T t)
  
  java.lang.Object getWayangFunction()
  - Methods inherited from class java.lang.Object
    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - KeyExtractor
```
public KeyExtractor(java.util.function.Function<T,K> impl)
```
- Method Detail
  - call
```
public scala.Tuple2<K,T> call(T t)
                             throws java.lang.Exception
```
    Specified by:
    
    call in interface org.apache.spark.api.java.function.PairFunction<T,K,T>
    
    Throws:
    
    java.lang.Exception
  - getWayangFunction
```
public java.lang.Object getWayangFunction()
```
    Specified by:
    
    getWayangFunction in interface FunctionCompiler.WayangSparkFunction
    
    Returns:
    
    the original code object as has been defined in the Wayang API