org.apache.giraph.comm.netty.handler

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>

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

org.apache.giraph.comm.netty.handler.RequestServerHandler<WorkerRequest<I,V,E>>

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

Type Parameters:

I - Vertex id

V - Vertex data

E - Edge data

M - Message data

All Implemented Interfaces:

io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler

public 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>
extends RequestServerHandler<WorkerRequest<I,V,E>>

Handler for requests on worker

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
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> Factory for WorkerRequestServerHandler

Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

io.netty.channel.ChannelHandler.Sharable

Field Summary

Fields inherited from class org.apache.giraph.comm.netty.handler.RequestServerHandler

flowControl, RESPONSE_BYTES

Constructor Summary

Constructors

Constructor and Description
WorkerRequestServerHandler(ServerData<I,V,E> serverData, WorkerRequestReservedMap workerRequestReservedMap, ImmutableClassesGiraphConfiguration conf, TaskInfo myTaskInfo, Thread.UncaughtExceptionHandler exceptionHandler, FlowControl flowControl) Constructor with external server data

Method Summary

Modifier and Type	Method and Description
void	processRequest(WorkerRequest<I,V,E> request) Process request

Methods inherited from class org.apache.giraph.comm.netty.handler.RequestServerHandler

channelActive, channelInactive, channelRead, exceptionCaught

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, userEventTriggered

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, handlerAdded, handlerRemoved, isSharable

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.netty.channel.ChannelHandler

handlerAdded, handlerRemoved

Constructor Detail

WorkerRequestServerHandler

public WorkerRequestServerHandler(ServerData<I,V,E> serverData,
                                  WorkerRequestReservedMap workerRequestReservedMap,
                                  ImmutableClassesGiraphConfiguration conf,
                                  TaskInfo myTaskInfo,
                                  Thread.UncaughtExceptionHandler exceptionHandler,
                                  FlowControl flowControl)

Constructor with external server data

Parameters:

serverData - Data held by the server

workerRequestReservedMap - Worker request reservation map

conf - Configuration

myTaskInfo - Current task info

exceptionHandler - Handles uncaught exceptions

flowControl - Reference to the flow control used

Method Detail

processRequest

public void processRequest(WorkerRequest<I,V,E> request)

Description copied from class: RequestServerHandler

Process request

Specified by:

processRequest in class RequestServerHandler<WorkerRequest<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>>

Parameters:

request - Request to process