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

Class ComputePerPartitionWrapper<R,V>

java.lang.Object

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

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

All Implemented Interfaces:

java.io.Serializable, java.util.function.Function<java.lang.Iterable<V>,java.lang.Iterable<R>>, ExtendedFunction, FunctionDescriptor.ExtendedSerializableFunction<java.lang.Iterable<V>,java.lang.Iterable<R>>, FunctionDescriptor.SerializableFunction<java.lang.Iterable<V>,java.lang.Iterable<R>>

public class ComputePerPartitionWrapper<R,V>
extends LogicalOperatorWrapperWithModel<java.lang.Iterable<R>,java.lang.Iterable<V>>

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.wayang.ml4all.abstraction.plan.wrappers.LogicalOperatorWrapperWithModel

ml4allModel

Constructor Summary

Constructors

Constructor	Description
ComputePerPartitionWrapper(Compute logOp)

Method Summary

Modifier and Type	Method	Description
java.lang.Iterable<R>	apply(java.lang.Iterable<V> o)
void	initialise()

Methods inherited from class org.apache.wayang.ml4all.abstraction.plan.wrappers.LogicalOperatorWrapperWithModel

finalise, open

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, compose

Constructor Detail

ComputePerPartitionWrapper

public ComputePerPartitionWrapper(Compute logOp)

Method Detail

apply

public java.lang.Iterable<R> apply(java.lang.Iterable<V> o)

initialise

public void initialise()

Specified by:

initialise in class LogicalOperatorWrapperWithModel<java.lang.Iterable<R>,java.lang.Iterable<V>>