Package org.apache.wayang.spark.compiler

Class FunctionCompiler.Reducer<Type>

java.lang.Object

org.apache.wayang.spark.compiler.FunctionCompiler.Reducer<Type>

All Implemented Interfaces:

java.io.Serializable, org.apache.spark.api.java.function.Function2<Type,Type,Type>, FunctionCompiler.WayangSparkFunction

Enclosing class:

FunctionCompiler

public static class FunctionCompiler.Reducer<Type>
extends java.lang.Object
implements org.apache.spark.api.java.function.Function2<Type,Type,Type>, FunctionCompiler.WayangSparkFunction

Spark function for aggregating data quanta.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
Reducer(java.util.function.BinaryOperator<Type> impl)

Method Summary

Modifier and Type	Method	Description
Type	call(Type i0, Type i1)
java.lang.Object	getWayangFunction()

Methods inherited from class java.lang.Object

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

Constructor Detail

Reducer

public Reducer(java.util.function.BinaryOperator<Type> impl)

Method Detail

call

public Type call(Type i0,
                 Type i1)
          throws java.lang.Exception

Specified by:

call in interface org.apache.spark.api.java.function.Function2<Type,Type,Type>

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