Package | Description |
---|---|
org.apache.giraph.comm.netty |
Package for netty implementations.
|
org.apache.giraph.graph |
Package of all the graph related objects, built on the
org.apache.bsp package.
|
org.apache.giraph.worker |
Package of all the worker related things
|
Modifier and Type | Class and Description |
---|---|
class |
NettyWorkerClientRequestProcessor<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
Aggregate requests and sends them to the thread-safe NettyClient.
|
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.
|
Modifier and Type | Field and Description |
---|---|
protected WorkerClientRequestProcessor<I,V,E> |
InputSplitsCallable.workerClientRequestProcessor
Handles IPC communication
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.