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

Packages that use WorkerGlobalCommUsage

Package	Description
org.apache.giraph.benchmark	Package of benchmarks for performance testing and optimization
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 WorkerGlobalCommUsage in org.apache.giraph.benchmark

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

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 WorkerGlobalCommUsage in org.apache.giraph.graph

Subinterfaces of WorkerGlobalCommUsage 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 WorkerGlobalCommUsage

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.

Methods in org.apache.giraph.graph with parameters of type WorkerGlobalCommUsage

Modifier and Type	Method and Description
void	AbstractComputation.initialize(GraphState graphState, WorkerClientRequestProcessor<I,V,E> workerClientRequestProcessor, CentralizedServiceWorker<I,V,E> serviceWorker, WorkerGlobalCommUsage workerGlobalCommUsage) Initialize, called by infrastructure before the superstep starts.
void	Computation.initialize(GraphState graphState, WorkerClientRequestProcessor<I,V,E> workerClientRequestProcessor, CentralizedServiceWorker<I,V,E> serviceWorker, WorkerGlobalCommUsage workerGlobalCommUsage) Initialize, called by infrastructure before the superstep starts.

Uses of WorkerGlobalCommUsage in org.apache.giraph.io

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

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 WorkerGlobalCommUsage in org.apache.giraph.io.formats

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

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 WorkerGlobalCommUsage in org.apache.giraph.io.internal

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

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.

Methods in org.apache.giraph.io.internal with parameters of type WorkerGlobalCommUsage

Modifier and Type	Method and Description
void	WrappedEdgeReader.setWorkerGlobalCommUsage(WorkerGlobalCommUsage usage)
void	WrappedMappingReader.setWorkerGlobalCommUsage(WorkerGlobalCommUsage usage)
void	WrappedVertexReader.setWorkerGlobalCommUsage(WorkerGlobalCommUsage usage)

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

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

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 WorkerGlobalCommUsage in org.apache.giraph.jython

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

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 WorkerGlobalCommUsage in org.apache.giraph.worker

Subinterfaces of WorkerGlobalCommUsage in org.apache.giraph.worker

Modifier and Type	Interface and Description
interface	WorkerThreadGlobalCommUsage WorkerAggregatorUsage which can be used in each of the computation threads.

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

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.

Methods in org.apache.giraph.worker with parameters of type WorkerGlobalCommUsage

Modifier and Type	Method and Description
void	WorkerAggregatorDelegator.setWorkerGlobalCommUsage(WorkerGlobalCommUsage workerGlobalCommUsage) Set worker global communication usage