org.apache.giraph.worker

Interface WorkerAggregatorUsage

All Superinterfaces:

AggregatorUsage

All Known Subinterfaces:

Computation<I,V,E,M1,M2>

All Known Implementing Classes:

AbstractComputation, AdjacencyListTextVertexInputFormat.AdjacencyListTextVertexReader, AggregatorsBenchmark.AggregatorsBenchmarkComputation, AggregatorsBenchmark.AggregatorsBenchmarkWorkerContext, BasicComputation, BasicVertexValueReader, DefaultWorkerContext, EdgeReader, EdgeReaderWrapper, IntIntNullTextInputFormat.IntIntNullVertexReader, IntIntNullTextVertexInputFormat.IntIntNullVertexReader, IntIntTextVertexValueInputFormat.IntIntTextVertexValueReader, IntNullNullTextInputFormat.IntNullNullNullVertexReader, IntNullTextEdgeInputFormat.IntNullTextEdgeReader, JsonBase64VertexInputFormat.JsonBase64VertexReader, JythonGiraphComputation, LongDoubleDoubleAdjacencyListVertexInputFormat.LongDoubleDoubleAdjacencyListVertexReader, LongLongNullTextInputFormat.LongLongNullVertexReader, MappingReader, MappingReaderWrapper, PageRankComputation, RandomMessageBenchmark.RandomMessageBenchmarkWorkerContext, RandomMessageBenchmark.RandomMessageComputation, ReducersBenchmark.ReducersBenchmarkComputation, ReducersBenchmark.ReducersBenchmarkWorkerContext, ReverseEdgeDuplicator, SequenceFileVertexInputFormat.SequenceFileVertexReader, ShortestPathsComputation, TextDoubleDoubleAdjacencyListVertexInputFormat.TextDoubleDoubleAdjacencyListVertexReader, TextEdgeInputFormat.TextEdgeReader, TextEdgeInputFormat.TextEdgeReaderFromEachLine, TextEdgeInputFormat.TextEdgeReaderFromEachLineProcessed, TextVertexInputFormat.TextVertexReader, TextVertexInputFormat.TextVertexReaderFromEachLine, TextVertexInputFormat.TextVertexReaderFromEachLineProcessed, TextVertexInputFormat.TextVertexReaderFromEachLineProcessedHandlingExceptions, TextVertexValueInputFormat.TextVertexValueReader, TextVertexValueInputFormat.TextVertexValueReaderFromEachLine, TextVertexValueInputFormat.TextVertexValueReaderFromEachLineProcessed, VertexReader, VertexReaderWrapper, VertexValueReader, WeightedPageRankComputation, WorkerAggregatorDelegator, WorkerContext, WrappedEdgeReader, WrappedMappingReader, WrappedVertexReader

public interface WorkerAggregatorUsage
extends AggregatorUsage

Vertex classes can access and change aggregators through this interface

Method Summary

Modifier and Type	Method and Description
<A extends org.apache.hadoop.io.Writable> void	aggregate(String name, A value) Add a new value

Methods inherited from interface org.apache.giraph.aggregators.AggregatorUsage

getAggregatedValue

Method Detail

aggregate

<A extends org.apache.hadoop.io.Writable> void aggregate(String name,
                                                         A value)

Add a new value

Type Parameters:

A - Aggregated value

Parameters:

name - Name of aggregator

value - Value to add