Package org.apache.wayang.giraph.Algorithm

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 with PageRankAlgorithm.

  • Constructor Summary

    Constructors
    Constructor
    Description
    PageRankWorkerContext()
     

  • Method Summary

    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

    Methods inherited from class org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable

    getConf, setConf

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • PageRankWorkerContext

      public PageRankWorkerContext()

  • Method Details

    • getFinalMax

      public static double getFinalMax()

    • getFinalMin

      public static double getFinalMin()

    • getFinalSum

      public static long getFinalSum()

    • preApplication

      public void preApplication() throws InstantiationException, IllegalAccessException
      Specified by:
      preApplication in class org.apache.giraph.worker.WorkerContext
      Throws:
      InstantiationException
      IllegalAccessException

    • postApplication

      public void postApplication()
      Specified by:
      postApplication in class org.apache.giraph.worker.WorkerContext

    • preSuperstep

      public void preSuperstep()
      Specified by:
      preSuperstep in class org.apache.giraph.worker.WorkerContext

    • postSuperstep

      public void postSuperstep()
      Specified by:
      postSuperstep in class org.apache.giraph.worker.WorkerContext