org.apache.giraph.comm.netty.handler

Class WorkerRequestServerHandler.Factory<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

java.lang.Object

org.apache.giraph.comm.netty.handler.WorkerRequestServerHandler.Factory<I,V,E>

All Implemented Interfaces:

RequestServerHandler.Factory

Enclosing class:

WorkerRequestServerHandler<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M extends org.apache.hadoop.io.Writable>

public static class WorkerRequestServerHandler.Factory<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
extends Object
implements RequestServerHandler.Factory

Factory for WorkerRequestServerHandler

Constructor Summary

Constructors

Constructor and Description
Factory(ServerData<I,V,E> serverData) 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(ServerData<I,V,E> serverData)

Constructor

Parameters:

serverData - Data held by the server

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