Package | Description |
---|---|
org.apache.giraph.bsp |
Package of generic bulk synchronous processing objects.
|
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.master |
Package of all the master related things.
|
Modifier and Type | Method and Description |
---|---|
MasterGlobalCommHandler |
CentralizedServiceMaster.getGlobalCommHandler()
Get handler for global communication
|
Constructor and Description |
---|
Factory(MasterGlobalCommHandler commHandler)
Constructor
|
MasterRequestServerHandler(WorkerRequestReservedMap workerRequestReservedMap,
ImmutableClassesGiraphConfiguration conf,
TaskInfo myTaskInfo,
MasterGlobalCommHandler commHandler,
Thread.UncaughtExceptionHandler exceptionHandler,
FlowControl flowControl)
Constructor
|
Modifier and Type | Method and Description |
---|---|
void |
PartitionStatsRequest.doRequest(MasterGlobalCommHandler commHandler) |
void |
AskForInputSplitRequest.doRequest(MasterGlobalCommHandler commHandler) |
void |
MasterRequest.doRequest(MasterGlobalCommHandler commHandler)
Execute the request
|
void |
SendReducedToMasterRequest.doRequest(MasterGlobalCommHandler commHandler) |
Modifier and Type | Method and Description |
---|---|
MasterGlobalCommHandler |
BspServiceMaster.getGlobalCommHandler() |
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.