org.apache.giraph.worker

Interface WorkerBroadcastUsage

All Known Subinterfaces:

BlockWorkerContextReceiveApi<I>, BlockWorkerReceiveApi<I>, Computation<I,V,E,M1,M2>, WorkerGlobalCommUsage, 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 WorkerBroadcastUsage

Methods on worker can access broadcasted values through this interface

Method Summary

Modifier and Type	Method and Description
<B extends org.apache.hadoop.io.Writable> B	getBroadcast(String name) Get value broadcasted from master

Method Detail

getBroadcast

<B extends org.apache.hadoop.io.Writable> B getBroadcast(String name)

Get value broadcasted from master

Type Parameters:

B - Broadcast value type

Parameters:

name - Name of the broadcasted value

Returns:

Broadcasted value