org.apache.flink.api.common.operators.base

Class BulkIterationBase.PartialSolutionPlaceHolder<OT>

java.lang.Object

org.apache.flink.api.common.operators.Operator<OT>

org.apache.flink.api.common.operators.base.BulkIterationBase.PartialSolutionPlaceHolder<OT>

All Implemented Interfaces:

Visitable<Operator<?>>

Enclosing class:

BulkIterationBase<T>

public static class BulkIterationBase.PartialSolutionPlaceHolder<OT>
extends Operator<OT>

Specialized operator to use as a recognizable place-holder for the input to the step function when composing the nested data flow.

Field Summary

Fields inherited from class org.apache.flink.api.common.operators.Operator

compilerHints, name, operatorInfo, parameters

Constructor Summary

Constructors

Constructor and Description
PartialSolutionPlaceHolder(BulkIterationBase<OT> container, OperatorInformation<OT> operatorInfo)

Method Summary

Modifier and Type	Method and Description
void	accept(Visitor<Operator<?>> visitor) Contains the logic to invoke the visitor and continue the traversal.
BulkIterationBase<OT>	getContainingBulkIteration()
UserCodeWrapper<?>	getUserCodeWrapper() Gets the user code wrapper.

Methods inherited from class org.apache.flink.api.common.operators.Operator

createUnionCascade, createUnionCascade, createUnionCascade, getCompilerHints, getMinResources, getName, getOperatorInfo, getParallelism, getParameters, getPreferredResources, setName, setParallelism, setParameter, setParameter, setParameter, setResources, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

PartialSolutionPlaceHolder

public PartialSolutionPlaceHolder(BulkIterationBase<OT> container,
                                  OperatorInformation<OT> operatorInfo)

Method Detail

getContainingBulkIteration

public BulkIterationBase<OT> getContainingBulkIteration()

accept

public void accept(Visitor<Operator<?>> visitor)

Description copied from interface: Visitable

Contains the logic to invoke the visitor and continue the traversal. Typically invokes the pre-visit method of the visitor, then sends the visitor to the children (or predecessors) and then invokes the post-visit method.

A typical code example is the following:

 public void accept(Visitor<Operator> visitor) {
     boolean descend = visitor.preVisit(this);
     if (descend) {
         if (this.input != null) {
             this.input.accept(visitor);
         }
         visitor.postVisit(this);
     }
 }
 

Parameters:

visitor - The visitor to be called with this object as the parameter.

See Also:

Visitor.preVisit(Visitable), Visitor.postVisit(Visitable)

getUserCodeWrapper

public UserCodeWrapper<?> getUserCodeWrapper()

Description copied from class: Operator

Gets the user code wrapper. In the case of a pact, that object will be the stub with the user function, in the case of an input or output format, it will be the format object.

Overrides:

getUserCodeWrapper in class Operator<OT>

Returns:

The class with the user code.