Package | Description |
---|---|
org.apache.giraph.bsp |
Package of generic bulk synchronous processing objects.
|
org.apache.giraph.comm |
Package of communication related objects, IPC service.
|
org.apache.giraph.comm.netty |
Package for netty implementations.
|
org.apache.giraph.comm.netty.handler |
Package for classes which handle requests and responses.
|
org.apache.giraph.comm.requests |
Package for requests.
|
org.apache.giraph.ooc |
Package of out-of-core related classes.
|
org.apache.giraph.worker |
Package of all the worker related things
|
Modifier and Type | Method and Description |
---|---|
ServerData<I,V,E> |
CentralizedServiceWorker.getServerData()
Get server data
|
Modifier and Type | Method and Description |
---|---|
ServerData<I,V,E> |
WorkerServer.getServerData()
Get server data
|
Modifier and Type | Method and Description |
---|---|
ServerData<I,V,E> |
NettyWorkerServer.getServerData() |
Constructor and Description |
---|
Factory(ServerData<I,V,E> serverData)
Constructor
|
WorkerRequestServerHandler(ServerData<I,V,E> serverData,
WorkerRequestReservedMap workerRequestReservedMap,
ImmutableClassesGiraphConfiguration conf,
TaskInfo myTaskInfo,
Thread.UncaughtExceptionHandler exceptionHandler,
FlowControl flowControl)
Constructor with external server data
|
Modifier and Type | Method and Description |
---|---|
void |
SendWorkerEdgesRequest.doRequest(ServerData serverData) |
void |
SendWorkerAggregatorsRequest.doRequest(ServerData serverData) |
void |
ReplyWithInputSplitRequest.doRequest(ServerData serverData) |
void |
SendResumeRequest.doRequest(ServerData serverData) |
void |
AddressesAndPartitionsRequest.doRequest(ServerData serverData) |
void |
SendAggregatorsToOwnerRequest.doRequest(ServerData serverData) |
void |
SendAggregatorsToWorkerRequest.doRequest(ServerData serverData) |
void |
SendWorkerMessagesRequest.doRequest(ServerData serverData) |
void |
SendWorkerOneMessageToManyRequest.doRequest(ServerData serverData) |
void |
SendPartitionCurrentMessagesRequest.doRequest(ServerData<I,V,E> serverData) |
void |
SendWorkerVerticesRequest.doRequest(ServerData<I,V,E> serverData) |
void |
SendPartitionMutationsRequest.doRequest(ServerData<I,V,E> serverData) |
void |
SendVertexRequest.doRequest(ServerData<I,V,E> serverData) |
void |
WorkerRequest.doRequest(ServerData<I,V,E> serverData)
Execute the request
|
void |
SendWorkerToWorkerMessageRequest.doRequest(ServerData<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable> serverData) |
Modifier and Type | Method and Description |
---|---|
ServerData |
OutOfCoreEngine.getServerData()
Get a reference to the server data
|
Modifier and Type | Method and Description |
---|---|
ServerData<I,V,E> |
BspServiceWorker.getServerData() |
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.