Uses of Interface
org.apache.giraph.bsp.CentralizedServiceWorker

Packages that use CentralizedServiceWorker

Package	Description
org.apache.giraph.comm	Package of communication related objects, IPC service.
org.apache.giraph.comm.messages	Package of classes for storing messages.
org.apache.giraph.comm.netty	Package for netty implementations.
org.apache.giraph.edge	Package of Vertex implementations.
org.apache.giraph.edge.primitives	Package of edge stores specialized for certain type of vertex ids.
org.apache.giraph.graph	Package of all the graph related objects, built on the org.apache.bsp package.
org.apache.giraph.ooc	Package of out-of-core related classes.
org.apache.giraph.worker	Package of all the worker related things

Uses of CentralizedServiceWorker in org.apache.giraph.comm

Methods in org.apache.giraph.comm that return CentralizedServiceWorker

Modifier and Type	Method and Description
protected CentralizedServiceWorker	SendDataCache.getServiceWorker() Get the service worker.
CentralizedServiceWorker<I,V,E>	ServerData.getServiceWorker() Get the reference of the service worker.

Constructors in org.apache.giraph.comm with parameters of type CentralizedServiceWorker

Constructor and Description
SendDataCache(ImmutableClassesGiraphConfiguration conf, CentralizedServiceWorker<?,?,?> serviceWorker, int maxRequestSize, float additionalRequestSize) Constructor.
SendEdgeCache(ImmutableClassesGiraphConfiguration conf, CentralizedServiceWorker<?,?,?> serviceWorker) Constructor
SendMessageCache(ImmutableClassesGiraphConfiguration conf, CentralizedServiceWorker<?,?,?> serviceWorker, NettyWorkerClientRequestProcessor<I,?,?> processor, int maxMsgSize) Constructor
SendOneMessageToManyCache(ImmutableClassesGiraphConfiguration conf, CentralizedServiceWorker<?,?,?> serviceWorker, NettyWorkerClientRequestProcessor<I,?,?> processor, int maxMsgSize) Constructor
SendPartitionCache(ImmutableClassesGiraphConfiguration<I,V,E> conf, CentralizedServiceWorker<?,?,?> serviceWorker) Constructor.
SendVertexIdDataCache(ImmutableClassesGiraphConfiguration conf, CentralizedServiceWorker<?,?,?> serviceWorker, int maxRequestSize, float additionalRequestSize) Constructor.
ServerData(CentralizedServiceWorker<I,V,E> service, WorkerServer workerServer, ImmutableClassesGiraphConfiguration<I,V,E> conf, org.apache.hadoop.mapreduce.Mapper.Context context) Constructor.

Uses of CentralizedServiceWorker in org.apache.giraph.comm.messages

Methods in org.apache.giraph.comm.messages with parameters of type CentralizedServiceWorker

Modifier and Type	Method and Description
static <I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable> MessageStoreFactory<I,M,MessageStore<I,M>>	OneMessagePerVertexStore.newFactory(CentralizedServiceWorker<I,?,?> service, ImmutableClassesGiraphConfiguration<I,?,?> config) Create new factory for this message store
static <I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable> MessageStoreFactory<I,M,MessageStore<I,M>>	ByteArrayMessagesPerVertexStore.newFactory(CentralizedServiceWorker<I,?,?> service, ImmutableClassesGiraphConfiguration<I,?,?> config) Create new factory for this message store

Uses of CentralizedServiceWorker in org.apache.giraph.comm.netty

Methods in org.apache.giraph.comm.netty that return CentralizedServiceWorker

Modifier and Type	Method and Description
CentralizedServiceWorker<I,V,E>	NettyWorkerClient.getService()

Constructors in org.apache.giraph.comm.netty with parameters of type CentralizedServiceWorker

Constructor and Description
NettyWorkerAggregatorRequestProcessor(org.apache.hadoop.util.Progressable progressable, ImmutableClassesGiraphConfiguration<?,?,?> configuration, CentralizedServiceWorker<?,?,?> serviceWorker) Constructor.
NettyWorkerClient(org.apache.hadoop.mapreduce.Mapper.Context context, ImmutableClassesGiraphConfiguration<I,V,E> configuration, CentralizedServiceWorker<I,V,E> service, Thread.UncaughtExceptionHandler exceptionHandler) Only constructor.
NettyWorkerClientRequestProcessor(org.apache.hadoop.mapreduce.Mapper.Context context, ImmutableClassesGiraphConfiguration<I,V,E> conf, CentralizedServiceWorker<I,V,E> serviceWorker, boolean useOneMessageToManyIdsEncoding) Constructor.
NettyWorkerServer(ImmutableClassesGiraphConfiguration<I,V,E> conf, CentralizedServiceWorker<I,V,E> service, org.apache.hadoop.mapreduce.Mapper.Context context, Thread.UncaughtExceptionHandler exceptionHandler) Constructor to start the server.

Uses of CentralizedServiceWorker in org.apache.giraph.edge

Fields in org.apache.giraph.edge declared as CentralizedServiceWorker

Modifier and Type	Field and Description
protected CentralizedServiceWorker<I,V,E>	InMemoryEdgeStoreFactory.service Service worker.
protected CentralizedServiceWorker<I,V,E>	AbstractEdgeStore.service Service worker.

Methods in org.apache.giraph.edge with parameters of type CentralizedServiceWorker

Modifier and Type	Method and Description
void	InMemoryEdgeStoreFactory.initialize(CentralizedServiceWorker<I,V,E> service, ImmutableClassesGiraphConfiguration<I,V,E> conf, org.apache.hadoop.util.Progressable progressable)
void	EdgeStoreFactory.initialize(CentralizedServiceWorker<I,V,E> service, ImmutableClassesGiraphConfiguration<I,V,E> conf, org.apache.hadoop.util.Progressable progressable) Implementation class should use this method of initialization of any required internal state.

Constructors in org.apache.giraph.edge with parameters of type CentralizedServiceWorker

Constructor and Description
AbstractEdgeStore(CentralizedServiceWorker<I,V,E> service, ImmutableClassesGiraphConfiguration<I,V,E> configuration, org.apache.hadoop.util.Progressable progressable) Constructor.
SimpleEdgeStore(CentralizedServiceWorker<I,V,E> service, ImmutableClassesGiraphConfiguration<I,V,E> configuration, org.apache.hadoop.util.Progressable progressable) Constructor.

Uses of CentralizedServiceWorker in org.apache.giraph.edge.primitives

Constructors in org.apache.giraph.edge.primitives with parameters of type CentralizedServiceWorker

Constructor and Description
IntEdgeStore(CentralizedServiceWorker<org.apache.hadoop.io.IntWritable,V,E> service, ImmutableClassesGiraphConfiguration<org.apache.hadoop.io.IntWritable,V,E> configuration, org.apache.hadoop.util.Progressable progressable) Constructor.
LongEdgeStore(CentralizedServiceWorker<org.apache.hadoop.io.LongWritable,V,E> service, ImmutableClassesGiraphConfiguration<org.apache.hadoop.io.LongWritable,V,E> configuration, org.apache.hadoop.util.Progressable progressable) Constructor.

Uses of CentralizedServiceWorker in org.apache.giraph.graph

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

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.

Constructors in org.apache.giraph.graph with parameters of type CentralizedServiceWorker

Constructor and Description
ComputeCallable(org.apache.hadoop.mapreduce.Mapper.Context context, GraphState graphState, MessageStore<I,M1> messageStore, ImmutableClassesGiraphConfiguration<I,V,E> configuration, CentralizedServiceWorker<I,V,E> serviceWorker) Constructor

Uses of CentralizedServiceWorker in org.apache.giraph.ooc

Methods in org.apache.giraph.ooc that return CentralizedServiceWorker

Modifier and Type	Method and Description
CentralizedServiceWorker	OutOfCoreEngine.getServiceWorker() Get a reference to the service worker

Constructors in org.apache.giraph.ooc with parameters of type CentralizedServiceWorker

Constructor and Description
OutOfCoreEngine(ImmutableClassesGiraphConfiguration<?,?,?> conf, CentralizedServiceWorker<?,?,?> service, NetworkMetrics networkMetrics) Constructor

Uses of CentralizedServiceWorker in org.apache.giraph.worker

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

Modifier and Type	Class and Description
class	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.

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

Modifier and Type	Method and Description
void	WorkerContext.setupSuperstep(CentralizedServiceWorker<?,?,?> serviceWorker) Setup superstep.

Constructors in org.apache.giraph.worker with parameters of type CentralizedServiceWorker

Constructor and Description
WorkerAggregatorHandler(CentralizedServiceWorker<?,?,?> serviceWorker, ImmutableClassesGiraphConfiguration conf, org.apache.hadoop.util.Progressable progressable) Constructor