org.apache.giraph.comm.netty.handler

Class MasterRequestServerHandler.Factory

java.lang.Object

org.apache.giraph.comm.netty.handler.MasterRequestServerHandler.Factory

All Implemented Interfaces:

RequestServerHandler.Factory

Enclosing class:

MasterRequestServerHandler

public static class MasterRequestServerHandler.Factory
extends Object
implements RequestServerHandler.Factory

Factory for MasterRequestServerHandler

Constructor Summary

Constructors

Constructor and Description
Factory(MasterGlobalCommHandler commHandler) Constructor

Method Summary

Modifier and Type	Method and Description
RequestServerHandler	newHandler(WorkerRequestReservedMap workerRequestReservedMap, ImmutableClassesGiraphConfiguration conf, TaskInfo myTaskInfo, Thread.UncaughtExceptionHandler exceptionHandler) Create new RequestServerHandler
void	setFlowControl(FlowControl flowControl) Inform the factory about the flow control policy used (this method should be called before any call to `#newHandle()`)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Factory

public Factory(MasterGlobalCommHandler commHandler)

Constructor

Parameters:

commHandler - Master global communication handler

Method Detail

newHandler

public RequestServerHandler newHandler(WorkerRequestReservedMap workerRequestReservedMap,
                                       ImmutableClassesGiraphConfiguration conf,
                                       TaskInfo myTaskInfo,
                                       Thread.UncaughtExceptionHandler exceptionHandler)

Description copied from interface: RequestServerHandler.Factory

Create new RequestServerHandler

Specified by:

newHandler in interface RequestServerHandler.Factory

Parameters:

workerRequestReservedMap - Worker request reservation map

conf - Configuration to use

myTaskInfo - Current task info

exceptionHandler - Handles uncaught exceptions

Returns:

New RequestServerHandler

setFlowControl

public void setFlowControl(FlowControl flowControl)

Description copied from interface: RequestServerHandler.Factory

Inform the factory about the flow control policy used (this method should be called before any call to `#newHandle()`)

Specified by:

setFlowControl in interface RequestServerHandler.Factory

Parameters:

flowControl - reference to flow control used