Uses of Interface
org.apache.giraph.worker.WorkerBroadcastUsage

Packages that use WorkerBroadcastUsage

Package	Description
org.apache.giraph.benchmark	Package of benchmarks for performance testing and optimization
org.apache.giraph.block_app.framework.api	Interfaces representing full API to the underlying graph processing system.
org.apache.giraph.block_app.framework.api.giraph	Giraph implementation of graph processing system API used by Blocks Framework.
org.apache.giraph.block_app.framework.piece.global_comm	Interfaces for Reducer and Broadcast Handles for automatic handling of global communication within Pieces, hiding a lot of it's complexities.
org.apache.giraph.block_app.framework.piece.global_comm.array	Interfaces representing arrays of individual handles.
org.apache.giraph.block_app.framework.piece.global_comm.internal	Reducer and Broadcast Handles internal implementation for automatic handling of global communication within Pieces, hiding a lot of it's complexities.
org.apache.giraph.block_app.framework.piece.global_comm.map	Interfaces representing map of individual handles
org.apache.giraph.block_app.migration	Migration utility for transforming standard Giraph applications, into Block Applications.
org.apache.giraph.block_app.reducers.array	Reducers for collecting arrays of objects.
org.apache.giraph.block_app.reducers.collect	Reducers for distributed collection of objects.
org.apache.giraph.examples	Package of Giraph examples.
org.apache.giraph.examples.block_app	Package of Giraph examples for Block Applications.
org.apache.giraph.examples.scc	Classes for Strongly Connected Components computation.
org.apache.giraph.graph	Package of all the graph related objects, built on the org.apache.bsp package.
org.apache.giraph.io	Input/Output related things.
org.apache.giraph.io.formats	Package of reusable library Giraph objects.
org.apache.giraph.io.internal	Input/Output classes for internal use only.
org.apache.giraph.io.iterables	Iterable wrappers for IO readers/writers
org.apache.giraph.jython	Jython integration.
org.apache.giraph.worker	Package of all the worker related things

Uses of WorkerBroadcastUsage in org.apache.giraph.benchmark

Classes in org.apache.giraph.benchmark that implement WorkerBroadcastUsage

Modifier and Type	Class and Description
static class	AggregatorsBenchmark.AggregatorsBenchmarkComputation Vertex class for AggregatorsBenchmark
static class	AggregatorsBenchmark.AggregatorsBenchmarkWorkerContext WorkerContext class for AggregatorsBenchmark
class	PageRankComputation Implementation of PageRank in which vertex ids are ints, page rank values are floats, and graph is unweighted.
static class	RandomMessageBenchmark.RandomMessageBenchmarkWorkerContext WorkerContext forRandomMessageBenchmark.
static class	RandomMessageBenchmark.RandomMessageComputation Actual message computation (messaging in this case)
static class	ReducersBenchmark.ReducersBenchmarkComputation Vertex class for ReducersBenchmark
static class	ReducersBenchmark.ReducersBenchmarkWorkerContext WorkerContext class for ReducersBenchmark
class	ShortestPathsComputation Shortest paths algorithm.
class	WeightedPageRankComputation Implementation of Page Rank algorithm on a weighted graph.

Uses of WorkerBroadcastUsage in org.apache.giraph.block_app.framework.api

Subinterfaces of WorkerBroadcastUsage in org.apache.giraph.block_app.framework.api

Modifier and Type	Interface and Description
interface	BlockWorkerContextReceiveApi<I extends org.apache.hadoop.io.WritableComparable> Block computation API available for worker context receive methods.
interface	BlockWorkerReceiveApi<I extends org.apache.hadoop.io.WritableComparable> Block computation API available for worker receive methods.

Uses of WorkerBroadcastUsage in org.apache.giraph.block_app.framework.api.giraph

Classes in org.apache.giraph.block_app.framework.api.giraph that implement WorkerBroadcastUsage

Modifier and Type	Class and Description
class	BlockComputation Computation that executes receiver and sender blocks passed into BlockWorkerPieces.
class	BlockWorkerContext WorkerContext that executes receiver and sender blocks passed into BlockWorkerPieces.

Uses of WorkerBroadcastUsage in org.apache.giraph.block_app.framework.piece.global_comm

Methods in org.apache.giraph.block_app.framework.piece.global_comm with parameters of type WorkerBroadcastUsage

Modifier and Type	Method and Description
R	ReducerAndBroadcastWrapperHandle.getBroadcast(WorkerBroadcastUsage worker) Get broadcasted value
T	BroadcastHandle.getBroadcast(WorkerBroadcastUsage worker) Get broadcasted value

Uses of WorkerBroadcastUsage in org.apache.giraph.block_app.framework.piece.global_comm.array

Methods in org.apache.giraph.block_app.framework.piece.global_comm.array with parameters of type WorkerBroadcastUsage

Modifier and Type	Method and Description
int	BroadcastArrayHandle.getBroadcastedSize(WorkerBroadcastUsage worker) Number of elements that were broadcasted.

Uses of WorkerBroadcastUsage in org.apache.giraph.block_app.framework.piece.global_comm.internal

Methods in org.apache.giraph.block_app.framework.piece.global_comm.internal with parameters of type WorkerBroadcastUsage

Modifier and Type	Method and Description
T	ReducersForPieceHandler.BroadcastHandleImpl.getBroadcast(WorkerBroadcastUsage worker)

Uses of WorkerBroadcastUsage in org.apache.giraph.block_app.framework.piece.global_comm.map

Methods in org.apache.giraph.block_app.framework.piece.global_comm.map with parameters of type WorkerBroadcastUsage

Modifier and Type	Method and Description
int	BroadcastMapHandle.getBroadcastedSize(WorkerBroadcastUsage worker) Number of elements that were broadcasted.

Uses of WorkerBroadcastUsage in org.apache.giraph.block_app.migration

Classes in org.apache.giraph.block_app.migration that implement WorkerBroadcastUsage

Modifier and Type	Class and Description
class	MigrationAbstractComputation<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M1 extends org.apache.hadoop.io.Writable,M2 extends org.apache.hadoop.io.Writable> Replacement for AbstractComputation when migrating to Blocks Framework, disallowing functions that are tied to execution order.
static class	MigrationAbstractComputation.MigrationBasicComputation<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M extends org.apache.hadoop.io.Writable> Drop-in replacement for BasicComputation when migrating to Blocks Framework, disallowing functions that are tied to execution order.
static class	MigrationAbstractComputation.MigrationFullAbstractComputation<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M1 extends org.apache.hadoop.io.Writable,M2 extends org.apache.hadoop.io.Writable> Drop-in replacement for AbstractComputation when migrating to Blocks Framework.
static class	MigrationAbstractComputation.MigrationFullBasicComputation<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M extends org.apache.hadoop.io.Writable> Drop-in replacement for BasicComputation when migrating to Blocks Framework.

Uses of WorkerBroadcastUsage in org.apache.giraph.block_app.reducers.array

Methods in org.apache.giraph.block_app.reducers.array with parameters of type WorkerBroadcastUsage

Modifier and Type	Method and Description
int	ArrayOfHandles.ArrayOfBroadcasts.getBroadcastedSize(WorkerBroadcastUsage worker)

Uses of WorkerBroadcastUsage in org.apache.giraph.block_app.reducers.collect

Methods in org.apache.giraph.block_app.reducers.collect with parameters of type WorkerBroadcastUsage

Modifier and Type	Method and Description
List<S>	CollectShardedReducerHandle.CollectShardedBroadcastHandle.createBroadcastResult(WorkerBroadcastUsage worker)
List<WArrayList>	CollectShardedTuplesOfPrimitivesReducerHandle.CollectShardedTuplesOfPrimitivesBroadcastHandle.createBroadcastResult(WorkerBroadcastUsage worker)
WArrayList<S>	CollectShardedPrimitiveReducerHandle.CollectShardedPrimitiveBroadcastHandle.createBroadcastResult(WorkerBroadcastUsage worker)
R	ShardedReducerHandle.ShardedBroadcastHandle.createBroadcastResult(WorkerBroadcastUsage worker)
List<WArrayList>	CollectShardedTuplesOfPrimitivesReducerHandle.CollectShardedTuplesOfPrimitivesReduceBroadcast.getBroadcast(WorkerBroadcastUsage worker) Get broadcasted value
R	ShardedReducerHandle.ShardedBroadcastHandle.getBroadcast(WorkerBroadcastUsage worker)

Uses of WorkerBroadcastUsage in org.apache.giraph.examples

Classes in org.apache.giraph.examples that implement WorkerBroadcastUsage

Modifier and Type	Class and Description
class	AggregatorsTestComputation Computation which uses aggrergators.
static class	AggregatorsTestComputation.SimpleEdgeReader Simple Edge Reader
static class	AggregatorsTestComputation.SimpleVertexReader Simple VertexReader
class	BrachaTouegDeadlockComputation This code demonstrates the Bracha Toueg deadlock detection algorithm.
class	ConnectedComponentsComputation Implementation of the HCC algorithm that identifies connected components and assigns each vertex its "component identifier" (the smallest vertex id in the component) The idea behind the algorithm is very simple: propagate the smallest vertex id along the edges to all vertices of a connected component.
class	GeneratedEdgeReader<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable> Used by GeneratedEdgeInputFormat to read some generated data
class	GeneratedVertexReader<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> Used by GeneratedVertexInputFormat to read some generated data
class	IdentityComputation<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M extends org.apache.hadoop.io.Writable> User applications can subclass IdentityComputation, which simply prints the results that have been read for testing IO related jobs under any inputformat
class	LongDoubleDoubleTextInputFormat.LongDoubleDoubleDoubleVertexReader Vertex reader associated with LongDoubleDoubleTextInputFormat.
class	LongDoubleFloatTextInputFormat.LongDoubleFloatVertexReader Vertex reader associated with LongDoubleDoubleTextInputFormat.
class	LongDoubleNullTextInputFormat.LongDoubleNullDoubleVertexReader Vertex reader associated with LongDoubleNullTextInputFormat.
class	MaxComputation Simple algorithm that computes the max value in the graph.
class	NormalizingLongDoubleDoubleTextInputFormat.NormalizingLongDoubleDoubleDoubleVertexReader Vertex reader associated with LongDoubleDoubleTextInputFormat.
class	PageRankWithKryoSimpleWritable Copy of SimplePageRank, modified to test vertex/edge and message values that derives from KryoSimpleWritable.
static class	PageRankWithKryoSimpleWritable.PageRankWithKryoVertexReader Simple VertexReader that supports PageRankWithKryoSimpleWritable
static class	PageRankWithKryoSimpleWritable.PageRankWithKryoWorkerContext Worker context used with PageRankWithKryoSimpleWritable.
class	RandomWalkComputation<E extends org.apache.hadoop.io.Writable> Base class for executing a random walk on a graph
class	RandomWalkWithRestartComputation Executes "RandomWalkWithRestart", a random walk on the graph which is biased towards a source vertex.
class	RandomWalkWorkerContext Worker context for random walks.
static class	SimpleCheckpoint.SimpleCheckpointComputation Actual computation.
static class	SimpleCheckpoint.SimpleCheckpointVertexWorkerContext Worker context associated with SimpleCheckpoint.
class	SimpleCombinerComputation Test whether messages can go through a combiner.
class	SimpleFailComputation Vertex to allow unit testing of failure detection
class	SimpleInDegreeCountComputation Simple function to return the out degree for each vertex.
class	SimpleLongDoubleDoubleDoubleIdentityComputation A simple use of the Identity Vertex for taking care of Long, Double, Double, Double type Inputformat Good for use with io.LongDoubleDoubleAdjacencyListVertexInputFormat
class	SimpleMasterComputeComputation Demonstrates a computation with a centralized part implemented via a MasterCompute.
static class	SimpleMasterComputeComputation.SimpleMasterComputeWorkerContext Worker context used with SimpleMasterComputeComputation.
class	SimpleMsgComputation Test whether messages can be sent and received by vertices.
class	SimpleMutateGraphComputation Vertex to allow unit testing of graph mutations.
static class	SimpleMutateGraphComputation.SimpleMutateGraphVertexWorkerContext Worker context used with SimpleMutateGraphComputation.
class	SimpleOutDegreeCountComputation Simple function to return the out degree for each vertex.
class	SimplePageRankComputation Demonstrates the basic Pregel PageRank implementation.
static class	SimplePageRankComputation.SimplePageRankVertexReader Simple VertexReader that supports SimplePageRankComputation
static class	SimplePageRankComputation.SimplePageRankWorkerContext Worker context used with SimplePageRankComputation.
class	SimpleShortestPathsComputation Demonstrates the basic Pregel shortest paths implementation.
class	SimpleSuperstepComputation Just a simple Vertex compute implementation that executes 3 supersteps, then finishes.
static class	SimpleSuperstepComputation.SimpleSuperstepVertexReader Simple VertexReader that supports SimpleSuperstepComputation
class	SimpleTriangleClosingComputation Demonstrates triangle closing in simple, unweighted graphs for Giraph.
static class	SimpleVertexWithWorkerContext.EmitterWorkerContext Example worker context to emit data as part of a superstep.
static class	SimpleVertexWithWorkerContext.SimpleComputation Actual vetex implementation
class	TestComputationStateComputation Vertex to test the local variables in Computation, and pre/postSuperstep methods
static class	TestComputationStateComputation.TestComputationStateWorkerContext WorkerContext for TestComputationState
static class	VerifyMessage.VerifyMessageComputation Send and verify messages.
static class	VerifyMessage.VerifyMessageComputation.VerifyMessageVertexWorkerContext Worker context used with VerifyMessage.VerifyMessageComputation.

Uses of WorkerBroadcastUsage in org.apache.giraph.examples.block_app

Classes in org.apache.giraph.examples.block_app that implement WorkerBroadcastUsage

Modifier and Type	Class and Description
static class	SimpleMigrationMasterBlockFactory.SimpleMigrationMasterComputation Demonstrates a computation with a centralized part implemented via a MasterCompute.

Uses of WorkerBroadcastUsage in org.apache.giraph.examples.scc

Classes in org.apache.giraph.examples.scc that implement WorkerBroadcastUsage

Modifier and Type	Class and Description
class	SccComputation Finds strongly connected components of the graph.
class	SccLongLongNullTextInputFormat.LongLongNullVertexReader Vertex reader associated with SccLongLongNullTextInputFormat.

Uses of WorkerBroadcastUsage in org.apache.giraph.graph

Subinterfaces of WorkerBroadcastUsage in org.apache.giraph.graph

Modifier and Type	Interface and Description
interface	Computation<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M1 extends org.apache.hadoop.io.Writable,M2 extends org.apache.hadoop.io.Writable> Interface for an application for computation.

Classes in org.apache.giraph.graph that implement WorkerBroadcastUsage

Modifier and Type	Class and Description
class	AbstractComputation<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M1 extends org.apache.hadoop.io.Writable,M2 extends org.apache.hadoop.io.Writable> See Computation for explanation of the interface.
class	BasicComputation<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M extends org.apache.hadoop.io.Writable> Computation in which both incoming and outgoing message types are the same.

Uses of WorkerBroadcastUsage in org.apache.giraph.io

Classes in org.apache.giraph.io that implement WorkerBroadcastUsage

Modifier and Type	Class and Description
class	BasicVertexValueReader<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable> Abstract base class for VertexValueReader.
class	EdgeReader<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable> Analogous to org.apache.giraph.bsp.BspRecordReader for edges.
class	MappingReader<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,B extends org.apache.hadoop.io.Writable> Will read the mapping from an input split.
class	ReverseEdgeDuplicator<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable> An EdgeReader that creates the opposite direction edge for each edge read.
class	VertexReader<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> Analogous to Hadoop's RecordReader for vertices.
class	VertexValueReader<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable> Vertex reader for VertexValueInputFormat.

Uses of WorkerBroadcastUsage in org.apache.giraph.io.formats

Classes in org.apache.giraph.io.formats that implement WorkerBroadcastUsage

Modifier and Type	Class and Description
protected class	AdjacencyListTextVertexInputFormat.AdjacencyListTextVertexReader Vertex reader associated with AdjacencyListTextVertexInputFormat.
class	IntIntNullTextInputFormat.IntIntNullVertexReader Vertex reader associated with IntIntNullTextInputFormat.
class	IntIntNullTextVertexInputFormat.IntIntNullVertexReader Vertex reader associated with IntIntNullTextVertexInputFormat.
class	IntIntTextVertexValueInputFormat.IntIntTextVertexValueReader VertexValueReader associated with IntIntTextVertexValueInputFormat.
class	IntNullNullTextInputFormat.IntNullNullNullVertexReader Reader for this InputFormat.
class	IntNullTextEdgeInputFormat.IntNullTextEdgeReader EdgeReader associated with IntNullTextEdgeInputFormat.
protected class	JsonBase64VertexInputFormat.JsonBase64VertexReader Simple reader that supports JsonBase64VertexInputFormat
protected class	LongDoubleDoubleAdjacencyListVertexInputFormat.LongDoubleDoubleAdjacencyListVertexReader VertexReader associated with LongDoubleDoubleAdjacencyListVertexInputFormat.
class	LongLongNullTextInputFormat.LongLongNullVertexReader Vertex reader associated with LongLongNullTextInputFormat.
static class	SequenceFileVertexInputFormat.SequenceFileVertexReader<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,X extends Vertex<I,V,E>> Vertex reader used with SequenceFileVertexInputFormat.
protected class	TextDoubleDoubleAdjacencyListVertexInputFormat.TextDoubleDoubleAdjacencyListVertexReader Vertex reader used with TextDoubleDoubleAdjacencyListVertexInputFormat
protected class	TextEdgeInputFormat.TextEdgeReader EdgeReader for TextEdgeInputFormat.
protected class	TextEdgeInputFormat.TextEdgeReaderFromEachLine Abstract class to be implemented by the user to read an edge from each text line.
protected class	TextEdgeInputFormat.TextEdgeReaderFromEachLineProcessed<T> Abstract class to be implemented by the user to read an edge from each text line after preprocessing it.
protected class	TextVertexInputFormat.TextVertexReader Abstract class to be implemented by the user based on their specific vertex input.
protected class	TextVertexInputFormat.TextVertexReaderFromEachLine Abstract class to be implemented by the user to read a vertex from each text line.
protected class	TextVertexInputFormat.TextVertexReaderFromEachLineProcessed<T> Abstract class to be implemented by the user to read a vertex from each text line after preprocessing it.
protected class	TextVertexInputFormat.TextVertexReaderFromEachLineProcessedHandlingExceptions<T,X extends Throwable> Abstract class to be implemented by the user to read a vertex from each text line after preprocessing it with exception handling.
protected class	TextVertexValueInputFormat.TextVertexValueReader VertexValueReader for VertexValueInputFormat.
protected class	TextVertexValueInputFormat.TextVertexValueReaderFromEachLine Abstract class to be implemented by the user to read a vertex value from each text line.
protected class	TextVertexValueInputFormat.TextVertexValueReaderFromEachLineProcessed<T> Abstract class to be implemented by the user to read a vertex value from each text line after preprocessing it.

Uses of WorkerBroadcastUsage in org.apache.giraph.io.internal

Classes in org.apache.giraph.io.internal that implement WorkerBroadcastUsage

Modifier and Type	Class and Description
class	WrappedEdgeReader<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable> For internal use only.
class	WrappedMappingReader<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,B extends org.apache.hadoop.io.Writable> For internal use only.
class	WrappedVertexReader<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> For internal use only.

Uses of WorkerBroadcastUsage in org.apache.giraph.io.iterables

Classes in org.apache.giraph.io.iterables that implement WorkerBroadcastUsage

Modifier and Type	Class and Description
class	EdgeReaderWrapper<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable> Wraps GiraphReader for edges into EdgeReader
class	MappingReaderWrapper<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,B extends org.apache.hadoop.io.Writable> Wraps GiraphReader for mapping into MappingReader
class	VertexReaderWrapper<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> Wraps GiraphReader for vertices into VertexReader

Uses of WorkerBroadcastUsage in org.apache.giraph.jython

Classes in org.apache.giraph.jython that implement WorkerBroadcastUsage

Modifier and Type	Class and Description
class	JythonGiraphComputation<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M1 extends org.apache.hadoop.io.Writable,M2 extends org.apache.hadoop.io.Writable> The Computation class for using Jython with Giraph.

Uses of WorkerBroadcastUsage in org.apache.giraph.worker

Subinterfaces of WorkerBroadcastUsage in org.apache.giraph.worker

Modifier and Type	Interface and Description
interface	WorkerGlobalCommUsage Methods on worker can access broadcasted values and provide values to reduce through this interface
interface	WorkerThreadGlobalCommUsage WorkerAggregatorUsage which can be used in each of the computation threads.

Classes in org.apache.giraph.worker that implement WorkerBroadcastUsage

Modifier and Type	Class and Description
class	DefaultWorkerContext A dummy implementation of WorkerContext.
class	WorkerAggregatorDelegator<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> Class for delegating WorkerAggregatorUsage and WorkerGlobalCommUsage methods to corresponding interface.
class	WorkerAggregatorHandler Handler for reduce/broadcast on the workers
class	WorkerAggregatorHandler.ThreadLocalWorkerGlobalCommUsage Not thread-safe implementation of WorkerThreadGlobalCommUsage.
class	WorkerContext WorkerContext allows for the execution of user code on a per-worker basis.