Package org.apache.wayang.core.function

Interface ExtendedFunction

All Known Subinterfaces:

FunctionDescriptor.ExtendedSerializableBinaryOperator<Type>, FunctionDescriptor.ExtendedSerializableConsumer<T>, FunctionDescriptor.ExtendedSerializableFunction<Input,Output>, FunctionDescriptor.ExtendedSerializablePredicate<T>

All Known Implementing Classes:

AssignWrapper, AssignWrapperLocal, ComputePerPartitionWrapper, ComputeWrapper, LogicalOperatorWrapperWithModel, LoopCheckWrapper, LoopConvergenceWrapper, PageRankMapping.RankInitializer, UpdateLocalWrapper, UpdateWrapper

public interface ExtendedFunction

Used to enrich regular functions with additional life-cycle methods of Operators.

Method Summary

Modifier and Type	Method	Description
void	open(ExecutionContext ctx)	Called before this instance is actually executed.

Method Detail

open

void open(ExecutionContext ctx)

Called before this instance is actually executed.

Parameters:

ctx - the ExecutionContext