Class BFS

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

    public class BFS
    extends org.apache.giraph.graph.BasicComputation<org.apache.hadoop.io.IntWritable,​org.apache.hadoop.io.IntWritable,​org.apache.hadoop.io.FloatWritable,​org.apache.hadoop.io.IntWritable>
    • Field Detail

      • SOURCE_ID

        public static final org.apache.giraph.conf.LongConfOption SOURCE_ID
        The start id
    • Constructor Detail

      • BFS

        public BFS()
    • Method Detail

      • compute

        public void compute​(org.apache.giraph.graph.Vertex<org.apache.hadoop.io.IntWritable,​org.apache.hadoop.io.IntWritable,​org.apache.hadoop.io.FloatWritable> vertex,
                            Iterable<org.apache.hadoop.io.IntWritable> 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