Class GiraphPageRankOperator
- java.lang.Object
-
- org.apache.wayang.core.plan.wayangplan.OperatorBase
-
- org.apache.wayang.core.plan.wayangplan.UnaryToUnaryOperator<Tuple2<java.lang.Long,java.lang.Long>,Tuple2<java.lang.Long,java.lang.Float>>
-
- org.apache.wayang.basic.operators.PageRankOperator
-
- org.apache.wayang.giraph.operators.GiraphPageRankOperator
-
- All Implemented Interfaces:
java.io.Serializable
,ActualOperator
,ElementaryOperator
,ExecutionOperator
,Operator
,GiraphExecutionOperator
public class GiraphPageRankOperator extends PageRankOperator implements GiraphExecutionOperator
PageRankOperator
implementation for theGiraphPlatform
.- See Also:
- Serialized Form
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.apache.wayang.core.plan.wayangplan.OperatorBase
OperatorBase.GsonSerializer
-
-
Field Summary
-
Fields inherited from class org.apache.wayang.basic.operators.PageRankOperator
dampingFactor, DEFAULT_DAMPING_FACTOR, DEFAULT_GRAPH_DENSITIY, graphDensity, numIterations
-
Fields inherited from class org.apache.wayang.core.plan.wayangplan.OperatorBase
inputSlots, outputSlots, STANDARD_OPERATOR_ARGS
-
Fields inherited from interface org.apache.wayang.core.plan.wayangplan.Operator
FIRST_EPOCH
-
-
Constructor Summary
Constructors Constructor Description GiraphPageRankOperator(java.lang.Integer numIterations)
GiraphPageRankOperator(PageRankOperator pageRankOperator)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>>
execute(ChannelInstance[] inputChannelInstances, ChannelInstance[] outputChannelInstances, GiraphExecutor giraphExecutor, OptimizationContext.OperatorContext operatorContext)
Evaluates this operator.java.util.Collection<java.lang.String>
getLoadProfileEstimatorConfigurationKeys()
Provide theConfiguration
keys for theLoadProfileEstimator
specification of this instance.java.lang.String
getPathOut(Configuration configuration)
Platform
getPlatform()
java.util.List<ChannelDescriptor>
getSupportedInputChannels(int index)
java.util.List<ChannelDescriptor>
getSupportedOutputChannels(int index)
Display the supportedChannel
s for a certainOutputSlot
.void
setPathOut(java.lang.String path, Configuration configuration)
-
Methods inherited from class org.apache.wayang.basic.operators.PageRankOperator
createCardinalityEstimator, getDampingFactor, getGraphDensity, getNumIterations
-
Methods inherited from class org.apache.wayang.core.plan.wayangplan.UnaryToUnaryOperator
getInput, getInputType, getOutput, getOutputType
-
Methods inherited from class org.apache.wayang.core.plan.wayangplan.OperatorBase
accept, addBroadcastInput, addTargetPlatform, at, collectMappedInputSlots, collectMappedOutputSlots, copy, createCopy, getAllInputs, getAllOutputs, getCardinalityEstimator, getContainer, getEpoch, getName, getOriginal, getSimpleClassName, getTargetPlatforms, isAuxiliary, isSupportingBroadcastInputs, propagateInputCardinality, propagateOutputCardinality, setAuxiliary, setCardinalityEstimator, setContainer, setEpoch, setName, toString
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
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, getOriginal, getOutputChannelDescriptor, 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
-
-
-
-
Constructor Detail
-
GiraphPageRankOperator
public GiraphPageRankOperator(java.lang.Integer numIterations)
-
GiraphPageRankOperator
public GiraphPageRankOperator(PageRankOperator pageRankOperator)
-
-
Method Detail
-
execute
public Tuple<java.util.Collection<ExecutionLineageNode>,java.util.Collection<ChannelInstance>> execute(ChannelInstance[] inputChannelInstances, ChannelInstance[] outputChannelInstances, GiraphExecutor giraphExecutor, OptimizationContext.OperatorContext operatorContext)
Description copied from interface:GiraphExecutionOperator
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.- Specified by:
execute
in interfaceGiraphExecutionOperator
- Parameters:
inputChannelInstances
-ChannelInstance
s that satisfy the inputs of this operatoroutputChannelInstances
-ChannelInstance
s that collect the outputs of this operatoroperatorContext
-OptimizationContext.OperatorContext
of this instance- Returns:
Collection
s of what has been executed and produced
-
getPlatform
public Platform getPlatform()
- Specified by:
getPlatform
in interfaceExecutionOperator
- Returns:
- the platform that can run this operator
-
getLoadProfileEstimatorConfigurationKeys
public java.util.Collection<java.lang.String> getLoadProfileEstimatorConfigurationKeys()
Description copied from interface:ExecutionOperator
Provide theConfiguration
keys for theLoadProfileEstimator
specification of this instance.- Specified by:
getLoadProfileEstimatorConfigurationKeys
in interfaceExecutionOperator
- Returns:
- the
Configuration
keys
-
getSupportedInputChannels
public java.util.List<ChannelDescriptor> getSupportedInputChannels(int index)
Description copied from interface:ExecutionOperator
- Specified by:
getSupportedInputChannels
in interfaceExecutionOperator
- Parameters:
index
- the index of theInputSlot
- Returns:
- an
List
ofChannel
s'Class
es, ordered by their preference of use
-
getSupportedOutputChannels
public java.util.List<ChannelDescriptor> getSupportedOutputChannels(int index)
Description copied from interface:ExecutionOperator
Display the supportedChannel
s for a certainOutputSlot
.- Specified by:
getSupportedOutputChannels
in interfaceExecutionOperator
- Parameters:
index
- the index of theOutputSlot
- Returns:
- an
List
ofChannel
s'Class
es, ordered by their preference of use - See Also:
ExecutionOperator.getOutputChannelDescriptor(int)
-
setPathOut
public void setPathOut(java.lang.String path, Configuration configuration)
-
getPathOut
public java.lang.String getPathOut(Configuration configuration)
-
-