Package org.apache.wayang.spark.compiler

Class FunctionCompiler.Reducer<Type>

java.lang.Object

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

All Implemented Interfaces:

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

Enclosing class:

FunctionCompiler

public static class FunctionCompiler.Reducer<Type>
extends 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(BinaryOperator<Type> impl)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

Reducer

public Reducer(BinaryOperator<Type> impl)

Method Details

call

public Type call(Type i0,
 Type i1)
          throws Exception

Specified by:

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

Throws:

Exception

getWayangFunction

public Object getWayangFunction()

Specified by:

getWayangFunction in interface FunctionCompiler.WayangSparkFunction

Returns:

the original code object as has been defined in the Wayang API