Package org.apache.wayang.giraph.operators

Interface GiraphExecutionOperator

All Superinterfaces:

ActualOperator, ElementaryOperator, ExecutionOperator, Operator, Serializable

All Known Implementing Classes:

GiraphPageRankOperator

public interface GiraphExecutionOperator
extends ExecutionOperator

ExecutionOperator that can be run by the GiraphExecutor.

Field Summary

Fields inherited from interface org.apache.wayang.core.plan.wayangplan.Operator

FIRST_EPOCH

Method Summary

Modifier and Type	Method	Description
Tuple<Collection<ExecutionLineageNode>,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, isConversion, isElementary, isExecutionOperator, isFeedbackInput, isFeedforwardOutput, isLoopHead, isLoopSubplan, isOwnerOf, isReading, isSink, isSource, isSubplan, isSupportingBroadcastInputs, isUnconnected, propagateInputCardinality, propagateOutputCardinality, propagateOutputCardinality, replaceWith, setContainer, setEpoch, setInput, setName, setOutput

Method Details

execute

Tuple<Collection<ExecutionLineageNode>,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 LazyExecutionLineageNodes of input and ouput ChannelInstances and providing a Collection of executed OptimizationContext.OperatorContexts.

Parameters:

inputs - ChannelInstances that satisfy the inputs of this operator

outputs - ChannelInstances that collect the outputs of this operator

operatorContext - OptimizationContext.OperatorContext of this instance

Returns:

Collections of what has been executed and produced