Interface GiraphExecutionOperator
-
- All Superinterfaces:
ActualOperator
,ElementaryOperator
,ExecutionOperator
,Operator
- All Known Implementing Classes:
GiraphPageRankOperator
public interface GiraphExecutionOperator extends ExecutionOperator
ExecutionOperator
that can be run by theGiraphExecutor
.
-
-
Field Summary
-
Fields inherited from interface org.apache.wayang.core.plan.wayangplan.Operator
FIRST_EPOCH
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>
execute(ChannelInstance[] inputs, ChannelInstance[] outputs, GiraphExecutor giraphExecutor, OptimizationContext.OperatorContext operatorContext)
Evaluates this operator.-
Methods inherited from interface org.apache.wayang.core.plan.wayangplan.ActualOperator
accept
-
Methods inherited from interface org.apache.wayang.core.plan.wayangplan.ElementaryOperator
createCardinalityEstimator, getCardinalityEstimator, isAuxiliary, setAuxiliary, setCardinalityEstimator
-
Methods inherited from interface org.apache.wayang.core.plan.wayangplan.ExecutionOperator
copy, createLoadProfileEstimator, createOutputChannelInstances, getLimitBaseKey, getLoadProfileEstimatorConfigurationKey, getLoadProfileEstimatorConfigurationKeys, getOriginal, getOutputChannelDescriptor, getPlatform, getSupportedInputChannels, getSupportedOutputChannels, isFiltered
-
Methods inherited from interface org.apache.wayang.core.plan.wayangplan.Operator
addBroadcastInput, addTargetPlatform, broadcastTo, broadcastTo, collectMappedInputSlots, collectMappedOutputSlots, connectTo, connectTo, getAllInputs, getAllOutputs, getCardinalityPusher, getContainer, getEffectiveOccupant, getEffectiveOccupant, getEpoch, getEstimationContextProperties, getForwards, getInnermostLoop, getInput, getInput, getLoopStack, getName, getNumBroadcastInputs, getNumInputs, getNumOutputs, getNumRegularInputs, getOuterInputSlot, getOutermostInputSlot, getOutermostOutputSlots, getOutput, getOutput, getParent, getTargetPlatforms, isAlternative, isElementary, isExecutionOperator, isFeedbackInput, isFeedforwardOutput, isLoopHead, isLoopSubplan, isOwnerOf, isReading, isSink, isSource, isSubplan, isSupportingBroadcastInputs, isUnconnected, propagateInputCardinality, propagateOutputCardinality, propagateOutputCardinality, setContainer, setEpoch, setInput, setName, setOutput
-
-
-
-
Method Detail
-
execute
Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>> execute(ChannelInstance[] inputs, ChannelInstance[] outputs, GiraphExecutor giraphExecutor, OptimizationContext.OperatorContext operatorContext)
Evaluates this operator. Takes a set of inputs and produces a set of outputs.In addition, this method should give feedback of what this instance was doing by wiring the
LazyExecutionLineageNode
s of input and ouputChannelInstance
s and providing aCollection
of executedOptimizationContext.OperatorContext
s.- Parameters:
inputs
-ChannelInstance
s that satisfy the inputs of this operatoroutputs
-ChannelInstance
s that collect the outputs of this operatoroperatorContext
-OptimizationContext.OperatorContext
of this instance- Returns:
Collection
s of what has been executed and produced
-
-