Class MaxApp

  • All Implemented Interfaces:
    org.apache.giraph.aggregators.AggregatorUsage, org.apache.giraph.conf.GiraphConfigurationSettable<org.apache.hadoop.io.LongWritable,​org.apache.hadoop.io.LongWritable,​org.apache.hadoop.io.DoubleWritable>, org.apache.giraph.conf.ImmutableClassesGiraphConfigurable<org.apache.hadoop.io.LongWritable,​org.apache.hadoop.io.LongWritable,​org.apache.hadoop.io.DoubleWritable>, org.apache.giraph.conf.TypesHolder<org.apache.hadoop.io.LongWritable,​org.apache.hadoop.io.LongWritable,​org.apache.hadoop.io.DoubleWritable,​org.apache.hadoop.io.LongWritable,​org.apache.hadoop.io.LongWritable>, org.apache.giraph.graph.Computation<org.apache.hadoop.io.LongWritable,​org.apache.hadoop.io.LongWritable,​org.apache.hadoop.io.DoubleWritable,​org.apache.hadoop.io.LongWritable,​org.apache.hadoop.io.LongWritable>, org.apache.giraph.worker.WorkerAggregatorUsage, org.apache.giraph.worker.WorkerBroadcastUsage, org.apache.giraph.worker.WorkerGlobalCommUsage, org.apache.giraph.worker.WorkerIndexUsage<org.apache.hadoop.io.LongWritable>, org.apache.giraph.worker.WorkerReduceUsage

    public class MaxApp
    extends org.apache.giraph.graph.BasicComputation<org.apache.hadoop.io.LongWritable,​org.apache.hadoop.io.LongWritable,​org.apache.hadoop.io.DoubleWritable,​org.apache.hadoop.io.LongWritable>
    • Constructor Detail

      • MaxApp

        public MaxApp()
    • Method Detail

      • compute

        public void compute​(org.apache.giraph.graph.Vertex<org.apache.hadoop.io.LongWritable,​org.apache.hadoop.io.LongWritable,​org.apache.hadoop.io.DoubleWritable> vertex,
                            Iterable<org.apache.hadoop.io.LongWritable> messages)
                     throws IOException
        Must be defined by user to do computation on a single Vertex.
        Parameters:
        vertex - Vertex
        messages - Messages that were sent to this vertex in the previous superstep. Each message is only guaranteed to have
        Throws:
        IOException