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.