Class PageRankAlgorithm.PageRankWorkerContext
- java.lang.Object
-
- org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable<I,V,E>
-
- org.apache.giraph.worker.WorkerAggregatorDelegator<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>
-
- org.apache.giraph.worker.WorkerContext
-
- org.apache.wayang.giraph.Algorithm.PageRankAlgorithm.PageRankWorkerContext
-
- All Implemented Interfaces:
org.apache.giraph.aggregators.AggregatorUsage
,org.apache.giraph.conf.GiraphConfigurationSettable<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>
,org.apache.giraph.conf.ImmutableClassesGiraphConfigurable<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>
,org.apache.giraph.worker.WorkerAggregatorUsage
,org.apache.giraph.worker.WorkerBroadcastUsage
,org.apache.giraph.worker.WorkerGlobalCommUsage
,org.apache.giraph.worker.WorkerIndexUsage<org.apache.hadoop.io.WritableComparable>
,org.apache.giraph.worker.WorkerReduceUsage
,org.apache.hadoop.io.Writable
- Enclosing class:
- PageRankAlgorithm
public static class PageRankAlgorithm.PageRankWorkerContext extends org.apache.giraph.worker.WorkerContext
Worker context used withPageRankAlgorithm
.
-
-
Constructor Summary
Constructors Constructor Description PageRankWorkerContext()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static double
getFinalMax()
static double
getFinalMin()
static long
getFinalSum()
void
postApplication()
void
postSuperstep()
void
preApplication()
void
preSuperstep()
-
Methods inherited from class org.apache.giraph.worker.WorkerContext
getAndClearMessagesFromOtherWorkers, getContext, getMyWorkerIndex, getSuperstep, getTotalNumEdges, getTotalNumVertices, getWorkerCount, getWorkerForVertex, logToCommandLine, readFields, sendMessageToWorker, setGraphState, setupSuperstep, write
-
Methods inherited from class org.apache.giraph.worker.WorkerAggregatorDelegator
aggregate, getAggregatedValue, getBroadcast, reduce, reduceMerge, setWorkerGlobalCommUsage
-
-
-
-
Method Detail
-
getFinalMax
public static double getFinalMax()
-
getFinalMin
public static double getFinalMin()
-
getFinalSum
public static long getFinalSum()
-
preApplication
public void preApplication() throws java.lang.InstantiationException, java.lang.IllegalAccessException
- Specified by:
preApplication
in classorg.apache.giraph.worker.WorkerContext
- Throws:
java.lang.InstantiationException
java.lang.IllegalAccessException
-
postApplication
public void postApplication()
- Specified by:
postApplication
in classorg.apache.giraph.worker.WorkerContext
-
preSuperstep
public void preSuperstep()
- Specified by:
preSuperstep
in classorg.apache.giraph.worker.WorkerContext
-
postSuperstep
public void postSuperstep()
- Specified by:
postSuperstep
in classorg.apache.giraph.worker.WorkerContext
-
-