Package org.apache.wayang.spark.compiler

Interface Summary

Interface	Description
FunctionCompiler.WayangSparkFunction	Describes functions coming from Wayang, designated for Spark.

Class Summary

Class	Description
BinaryOperatorAdapter<Type>	Wraps a BinaryOperator as a Function2.
ExtendedBinaryOperatorAdapter<Type>	Implements a Function2 that calls ExtendedFunction.open(ExecutionContext) of its implementation before delegating the very first Function2.call(Object, Object).
ExtendedFlatMapFunctionAdapter<InputType,OutputType>	Implements a FlatMapFunction that calls ExtendedFunction.open(ExecutionContext) of its implementation before delegating the very first Function.call(Object).
ExtendedFunction<InputType,OutputType>	Implements a Function that calls ExtendedFunction.open(ExecutionContext) of its implementation before delegating the very first Function.call(Object).
ExtendedMapFunctionAdapter<InputType,OutputType>	Implements a Function that calls ExtendedFunction.open(ExecutionContext) of its implementation before delegating the very first Function.call(Object).
ExtendedMapPartitionsFunctionAdapter<InputType,OutputType>	Wraps a Function as a FlatMapFunction.
ExtendedPredicateAdapater<Type>	Implements a Function that calls ExtendedFunction.open(ExecutionContext) of its implementation before delegating the very first Function.call(Object).
FlatMapFunctionAdapter<InputType,OutputType>	Wraps a Function as a FlatMapFunction.
FunctionCompiler	A compiler translates Wayang functions into executable Java functions.
FunctionCompiler.KeyExtractor<T,K>	Spark function for building pair RDDs.
FunctionCompiler.Reducer<Type>	Spark function for aggregating data quanta.
MapFunctionAdapter<InputType,OutputType>	Wraps a Function as a Function.
MapPartitionsFunctionAdapter<InputType,OutputType>	Wraps a Function as a FlatMapFunction.
PredicateAdapter<InputType>	Wraps a Predicate as a Function.