Package org.apache.wayang.ml4all.abstraction.plan.wrappers

Class LogicalOperatorWrapperWithModel<R,V>

java.lang.Object

org.apache.wayang.ml4all.abstraction.plan.wrappers.LogicalOperatorWrapperWithModel<R,V>

All Implemented Interfaces:

Serializable, Function<V,R>, ExtendedFunction, FunctionDescriptor.ExtendedSerializableFunction<V,R>, FunctionDescriptor.SerializableFunction<V,R>

Direct Known Subclasses:

AssignWrapper, AssignWrapperLocal, ComputePerPartitionWrapper, ComputeWrapper, LoopCheckWrapper, LoopConvergenceWrapper, UpdateLocalWrapper, UpdateWrapper

public abstract class LogicalOperatorWrapperWithModel<R,V>
extends Object
implements FunctionDescriptor.ExtendedSerializableFunction<V,R>

Logical Operator that uses the [[org.apache.wayang.ml4all.abstraction.plan.ML4allModel]] as input besides the data flowing from its input slot. The model is broadcasted to the operator.

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected ML4allModel	ml4allModel

Constructor Summary

Constructors

Constructor	Description
LogicalOperatorWrapperWithModel()

Method Summary

Modifier and Type	Method	Description
void	finalise()
abstract void	initialise()
void	open(ExecutionContext executionContext)	Called before this instance is actually executed.

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Function

andThen, apply, compose

Field Details

ml4allModel

protected ML4allModel ml4allModel

Constructor Details

LogicalOperatorWrapperWithModel

public LogicalOperatorWrapperWithModel()

Method Details

open

public void open(ExecutionContext executionContext)

Description copied from interface: ExtendedFunction

Called before this instance is actually executed.

Specified by:

open in interface ExtendedFunction

Parameters:

executionContext - the ExecutionContext

initialise

public abstract void initialise()

finalise

public void finalise()