Package | Description |
---|---|
org.apache.giraph.comm |
Package of communication related objects, IPC service.
|
org.apache.giraph.comm.flow_control |
Package for flow-control policies.
|
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.ooc |
Package of out-of-core related classes.
|
Modifier and Type | Method and Description |
---|---|
FlowControl |
MasterClient.getFlowControl()
Get the reference to the flow control policy used for sending requests
|
FlowControl |
WorkerClient.getFlowControl() |
Modifier and Type | Method and Description |
---|---|
void |
MasterServer.setFlowControl(FlowControl flowControl)
Inform the server about the flow control policy used in sending requests
|
void |
WorkerServer.setFlowControl(FlowControl flowControl)
Inform this server about the flow control used in sending requests
|
Modifier and Type | Class and Description |
---|---|
class |
CreditBasedFlowControl
Representation of credit-based flow control policy.
|
class |
NoOpFlowControl
Representation of a flow control policy that does not do anything other than
the vanilla network client request transfer mechanism
|
class |
StaticFlowControl
Representation of a flow control that limits the aggregate number of open
requests to all other workers to a constant user-defined value
|
Modifier and Type | Method and Description |
---|---|
FlowControl |
NettyMasterClient.getFlowControl() |
FlowControl |
NettyWorkerClient.getFlowControl() |
FlowControl |
NettyClient.getFlowControl() |
Modifier and Type | Method and Description |
---|---|
void |
NettyMasterServer.setFlowControl(FlowControl flowControl) |
void |
NettyServer.setFlowControl(FlowControl flowControl)
Inform the server about the flow control policy used in sending requests
|
void |
NettyWorkerServer.setFlowControl(FlowControl flowControl) |
Modifier and Type | Field and Description |
---|---|
protected FlowControl |
RequestServerHandler.flowControl
Flow control used in sending requests
|
Modifier and Type | Method and Description |
---|---|
void |
WorkerRequestServerHandler.Factory.setFlowControl(FlowControl flowControl) |
void |
MasterRequestServerHandler.Factory.setFlowControl(FlowControl flowControl) |
void |
RequestServerHandler.Factory.setFlowControl(FlowControl flowControl)
Inform the factory about the flow control policy used (this method should
be called before any call to `#newHandle()`)
|
Constructor and Description |
---|
MasterRequestServerHandler(WorkerRequestReservedMap workerRequestReservedMap,
ImmutableClassesGiraphConfiguration conf,
TaskInfo myTaskInfo,
MasterGlobalCommHandler commHandler,
Thread.UncaughtExceptionHandler exceptionHandler,
FlowControl flowControl)
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 |
---|---|
FlowControl |
OutOfCoreEngine.getFlowControl() |
Modifier and Type | Method and Description |
---|---|
void |
OutOfCoreEngine.setFlowControl(FlowControl flowControl) |
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.