org.apache.giraph.worker

Interface WorkerAggregatorUsage

All Superinterfaces:

AggregatorUsage

All Known Subinterfaces:

BlockWorkerContextSendApi<I,WM>, BlockWorkerSendApi<I,V,E,M>, Computation<I,V,E,M1,M2>

All Known Implementing Classes:

AbstractComputation, AdjacencyListTextVertexInputFormat.AdjacencyListTextVertexReader, AggregatorsBenchmark.AggregatorsBenchmarkComputation, AggregatorsBenchmark.AggregatorsBenchmarkWorkerContext, AggregatorsTestComputation, AggregatorsTestComputation.SimpleEdgeReader, AggregatorsTestComputation.SimpleVertexReader, BasicComputation, BasicVertexValueReader, BlockComputation, BlockWorkerContext, BrachaTouegDeadlockComputation, ConnectedComponentsComputation, DefaultWorkerContext, EdgeReader, EdgeReaderWrapper, GeneratedEdgeReader, GeneratedVertexReader, IdentityComputation, IntIntNullTextInputFormat.IntIntNullVertexReader, IntIntNullTextVertexInputFormat.IntIntNullVertexReader, IntIntTextVertexValueInputFormat.IntIntTextVertexValueReader, IntNullNullTextInputFormat.IntNullNullNullVertexReader, IntNullTextEdgeInputFormat.IntNullTextEdgeReader, JsonBase64VertexInputFormat.JsonBase64VertexReader, JythonGiraphComputation, LongDoubleDoubleAdjacencyListVertexInputFormat.LongDoubleDoubleAdjacencyListVertexReader, LongDoubleDoubleTextInputFormat.LongDoubleDoubleDoubleVertexReader, LongDoubleFloatTextInputFormat.LongDoubleFloatVertexReader, LongDoubleNullTextInputFormat.LongDoubleNullDoubleVertexReader, LongLongNullTextInputFormat.LongLongNullVertexReader, MappingReader, MappingReaderWrapper, MaxComputation, MigrationAbstractComputation, MigrationAbstractComputation.MigrationBasicComputation, MigrationAbstractComputation.MigrationFullAbstractComputation, MigrationAbstractComputation.MigrationFullBasicComputation, NormalizingLongDoubleDoubleTextInputFormat.NormalizingLongDoubleDoubleDoubleVertexReader, PageRankComputation, PageRankComputation, PageRankWithKryoSimpleWritable, PageRankWithKryoSimpleWritable.PageRankWithKryoVertexReader, PageRankWithKryoSimpleWritable.PageRankWithKryoWorkerContext, RandomMessageBenchmark.RandomMessageBenchmarkWorkerContext, RandomMessageBenchmark.RandomMessageComputation, RandomWalkComputation, RandomWalkWithRestartComputation, RandomWalkWorkerContext, ReducersBenchmark.ReducersBenchmarkComputation, ReducersBenchmark.ReducersBenchmarkWorkerContext, ReverseEdgeDuplicator, SccComputation, SccLongLongNullTextInputFormat.LongLongNullVertexReader, SequenceFileVertexInputFormat.SequenceFileVertexReader, ShortestPathsComputation, SimpleCheckpoint.SimpleCheckpointComputation, SimpleCheckpoint.SimpleCheckpointVertexWorkerContext, SimpleCombinerComputation, SimpleFailComputation, SimpleInDegreeCountComputation, SimpleLongDoubleDoubleDoubleIdentityComputation, SimpleMasterComputeComputation, SimpleMasterComputeComputation.SimpleMasterComputeWorkerContext, SimpleMigrationMasterBlockFactory.SimpleMigrationMasterComputation, SimpleMsgComputation, SimpleMutateGraphComputation, SimpleMutateGraphComputation.SimpleMutateGraphVertexWorkerContext, SimpleOutDegreeCountComputation, SimplePageRankComputation, SimplePageRankComputation.SimplePageRankVertexReader, SimplePageRankComputation.SimplePageRankWorkerContext, SimpleShortestPathsComputation, SimpleSuperstepComputation, SimpleSuperstepComputation.SimpleSuperstepVertexReader, SimpleTriangleClosingComputation, SimpleVertexWithWorkerContext.EmitterWorkerContext, SimpleVertexWithWorkerContext.SimpleComputation, TestComputationStateComputation, TestComputationStateComputation.TestComputationStateWorkerContext, TextDoubleDoubleAdjacencyListVertexInputFormat.TextDoubleDoubleAdjacencyListVertexReader, TextEdgeInputFormat.TextEdgeReader, TextEdgeInputFormat.TextEdgeReaderFromEachLine, TextEdgeInputFormat.TextEdgeReaderFromEachLineProcessed, TextVertexInputFormat.TextVertexReader, TextVertexInputFormat.TextVertexReaderFromEachLine, TextVertexInputFormat.TextVertexReaderFromEachLineProcessed, TextVertexInputFormat.TextVertexReaderFromEachLineProcessedHandlingExceptions, TextVertexValueInputFormat.TextVertexValueReader, TextVertexValueInputFormat.TextVertexValueReaderFromEachLine, TextVertexValueInputFormat.TextVertexValueReaderFromEachLineProcessed, VerifyMessage.VerifyMessageComputation, VerifyMessage.VerifyMessageComputation.VerifyMessageVertexWorkerContext, 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