Package org.apache.giraph.worker

Package of all the worker related things

See: Description

Interface Summary

Interface	Description
WorkerAggregatorUsage	Vertex classes can access and change aggregators through this interface
WorkerBroadcastUsage	Methods on worker can access broadcasted values through this interface
WorkerGlobalCommUsage	Methods on worker can access broadcasted values and provide values to reduce through this interface
WorkerIndexUsage<I>	Interface providing utilities for using worker index.
WorkerObserver	Observer for worker.
WorkerReduceUsage	Methods on worker can provide values to reduce through this interface
WorkerThreadGlobalCommUsage	WorkerAggregatorUsage which can be used in each of the computation threads.

Class Summary

Class	Description
AllWorkersInfo	Information about all workers, their WorkerInfo values, and indices.
BspServiceWorker<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>	ZooKeeper-based implementation of CentralizedServiceWorker.
DefaultWorkerContext	A dummy implementation of WorkerContext.
DefaultWorkerObserver	Default Observer for Worker that does nothing.
EdgeInputSplitsCallable<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>	Load as many edge input splits as possible.
EdgeInputSplitsCallableFactory<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>	Factory for EdgeInputSplitsCallables.
InputSplitsCallable<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>	Abstract base class for loading vertex/edge input splits.
LocalData<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>	Stores LocalData for each worker
MappingInputSplitsCallable<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>	Load as many mapping input splits as possible.
MappingInputSplitsCallableFactory<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>	Factory for MappingInputSplitsCallables.
MemoryObserver	Memory observer to help synchronize when full gcs are happening across all the workers
VertexInputSplitsCallable<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>	Load as many vertex input splits as possible.
VertexInputSplitsCallableFactory<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>	Factory for VertexInputSplitsCallables.
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.
WorkerAggregatorHandler	Handler for reduce/broadcast on the workers
WorkerContext	WorkerContext allows for the execution of user code on a per-worker basis.
WorkerInfo	Information about a worker that is sent to the master and other workers.
WorkerInputSplitsHandler	Requests splits from master and keeps track of them
WorkerProgress	Stores information about a worker's progress that is periodically written to ZooKeeper with WorkerProgressWriter.
WorkerProgressStats	Stats about a worker's progress
WorkerProgressWriter	Class which periodically writes worker's progress to zookeeper

Package org.apache.giraph.worker Description

Package of all the worker related things