Package | Description |
---|---|
org.apache.giraph.bsp |
Package of generic bulk synchronous processing objects.
|
org.apache.giraph.comm.netty |
Package for netty implementations.
|
org.apache.giraph.worker |
Package of all the worker related things
|
Modifier and Type | Method and Description |
---|---|
WorkerClient<I,V,E> |
CentralizedServiceWorker.getWorkerClient()
Get the worker client (for instantiating WorkerClientRequestProcessor
instances.
|
Modifier and Type | Class and Description |
---|---|
class |
NettyWorkerClient<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
Takes users facing APIs in
WorkerClient and implements them
using the available WritableRequest objects. |
Modifier and Type | Method and Description |
---|---|
WorkerClient<I,V,E> |
BspServiceWorker.getWorkerClient() |
Constructor and Description |
---|
WorkerInputSplitsHandler(WorkerInfo workerInfo,
int masterTaskId,
WorkerClient workerClient)
Constructor
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.