Uses of Interface
org.apache.giraph.comm.flow_control.FlowControl

Packages that use FlowControl

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.

Uses of FlowControl in org.apache.giraph.comm

Methods in org.apache.giraph.comm that return FlowControl

Modifier and Type	Method and Description
FlowControl	MasterClient.getFlowControl() Get the reference to the flow control policy used for sending requests
FlowControl	WorkerClient.getFlowControl()

Methods in org.apache.giraph.comm with parameters of type FlowControl

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

Uses of FlowControl in org.apache.giraph.comm.flow_control

Classes in org.apache.giraph.comm.flow_control that implement FlowControl

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

Uses of FlowControl in org.apache.giraph.comm.netty

Methods in org.apache.giraph.comm.netty that return FlowControl

Modifier and Type	Method and Description
FlowControl	NettyMasterClient.getFlowControl()
FlowControl	NettyWorkerClient.getFlowControl()
FlowControl	NettyClient.getFlowControl()

Methods in org.apache.giraph.comm.netty with parameters of type FlowControl

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)

Uses of FlowControl in org.apache.giraph.comm.netty.handler

Fields in org.apache.giraph.comm.netty.handler declared as FlowControl

Modifier and Type	Field and Description
protected FlowControl	RequestServerHandler.flowControl Flow control used in sending requests

Methods in org.apache.giraph.comm.netty.handler with parameters of type FlowControl

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()`)

Constructors in org.apache.giraph.comm.netty.handler with parameters of type FlowControl

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

Uses of FlowControl in org.apache.giraph.ooc

Methods in org.apache.giraph.ooc that return FlowControl

Modifier and Type	Method and Description
FlowControl	OutOfCoreEngine.getFlowControl()

Methods in org.apache.giraph.ooc with parameters of type FlowControl

Modifier and Type	Method and Description
void	OutOfCoreEngine.setFlowControl(FlowControl flowControl)