Package org.apache.wayang.core.function

Interface Summary

Interface	Description
ExecutionContext	While a function is executed on a certain Platform, allows access to some information of the context in which the function is being executed.
ExtendedFunction	Used to enrich regular functions with additional life-cycle methods of Operators.
FunctionDescriptor.ExtendedSerializableBinaryOperator<Type>	Extends a FunctionDescriptor.SerializableBinaryOperator to an ExtendedFunction.
FunctionDescriptor.ExtendedSerializableConsumer<T>	Extends a FunctionDescriptor.SerializableConsumer to an ExtendedFunction.
FunctionDescriptor.ExtendedSerializableFunction<Input,Output>	Extends a FunctionDescriptor.SerializableFunction to an ExtendedFunction.
FunctionDescriptor.ExtendedSerializablePredicate<T>
FunctionDescriptor.SerializableBiFunction<Input0,Input1,Output>	Decorates the default Function with Serializable, which is required by some distributed frameworks.
FunctionDescriptor.SerializableBinaryOperator<Type>	Decorates the default Function with Serializable, which is required by some distributed frameworks.
FunctionDescriptor.SerializableConsumer<T>	Decorates the default Consumer with Serializable, which is required by some distributed frameworks.
FunctionDescriptor.SerializableFunction<Input,Output>	Decorates the default Function with Serializable, which is required by some distributed frameworks.
FunctionDescriptor.SerializableIntUnaryOperator
FunctionDescriptor.SerializableLongUnaryOperator
FunctionDescriptor.SerializablePredicate<T>
FunctionDescriptor.SerializableToDoubleBiFunction<T,U>
FunctionDescriptor.SerializableToLongBiFunction<T,U>
FunctionDescriptor.SerializableToLongFunction<T>

Class Summary

Class	Description
AggregationDescriptor<InputType,OutputType>	This descriptor pertains to functions that take multiple data units and aggregate them into a single data unit.
ConsumerDescriptor<T>	Created by bertty on 13-07-17.
FlatMapDescriptor<Input,Output>	This descriptor pertains to functions that consume a single data unit and output a group of data units.
FunctionDescriptor	A function operates on single data units or collections of those.
MapPartitionsDescriptor<Input,Output>	This descriptor pertains to functions that consume and output multiple data quanta.
PredicateDescriptor<Input>	This descriptor pertains to predicates that consume a single data unit.
ReduceDescriptor<Type>	This descriptor pertains to functions that take multiple data units and aggregate them into a single data unit by means of a tree-like fold, i.e., using a commutative, associative function..
TransformationDescriptor<Input,Output>	This descriptor pertains to functions that consume a single data unit and output a single data unit.