org.apache.giraph.worker

Interface WorkerGlobalCommUsage

All Superinterfaces:

WorkerBroadcastUsage, WorkerReduceUsage

All Known Subinterfaces:

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

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, WorkerAggregatorHandler, WorkerAggregatorHandler.ThreadLocalWorkerGlobalCommUsage, WorkerContext, WrappedEdgeReader, WrappedMappingReader, WrappedVertexReader

public interface WorkerGlobalCommUsage
extends WorkerBroadcastUsage, WorkerReduceUsage

Methods on worker can access broadcasted values and provide values to reduce through this interface

Method Summary

Methods inherited from interface org.apache.giraph.worker.WorkerBroadcastUsage

getBroadcast

Methods inherited from interface org.apache.giraph.worker.WorkerReduceUsage

reduce, reduceMerge