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.WorkerContextWorker 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 doublegetFinalMax()static doublegetFinalMin()static longgetFinalSum()voidpostApplication()voidpostSuperstep()voidpreApplication()voidpreSuperstep()-
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:
preApplicationin classorg.apache.giraph.worker.WorkerContext- Throws:
java.lang.InstantiationExceptionjava.lang.IllegalAccessException
-
postApplication
public void postApplication()
- Specified by:
postApplicationin classorg.apache.giraph.worker.WorkerContext
-
preSuperstep
public void preSuperstep()
- Specified by:
preSuperstepin classorg.apache.giraph.worker.WorkerContext
-
postSuperstep
public void postSuperstep()
- Specified by:
postSuperstepin classorg.apache.giraph.worker.WorkerContext
-
-