org.apache.giraph.comm.netty.handler

Interface RequestServerHandler.Factory

All Known Implementing Classes:

MasterRequestServerHandler.Factory, WorkerRequestServerHandler.Factory

Enclosing class:

RequestServerHandler<R>

public static interface RequestServerHandler.Factory

Factory for RequestServerHandler

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

Method Detail

newHandler

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

Create new RequestServerHandler

Parameters:

workerRequestReservedMap - Worker request reservation map

conf - Configuration to use

myTaskInfo - Current task info

exceptionHandler - Handles uncaught exceptions

Returns:

New RequestServerHandler

setFlowControl

void setFlowControl(FlowControl flowControl)

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

Parameters:

flowControl - reference to flow control used