org.apache.drill.exec.rpc.control

Class CustomHandlerRegistry

java.lang.Object

org.apache.drill.exec.rpc.control.CustomHandlerRegistry

public class CustomHandlerRegistry
extends Object

Constructor Summary

Constructors

Constructor and Description
CustomHandlerRegistry()

Method Summary

Modifier and Type	Method and Description
Response	handle(BitControl.CustomMessage message, DrillBuf dBody)
<REQUEST,RESPONSE> void	registerCustomHandler(int messageTypeId, Controller.CustomMessageHandler<REQUEST,RESPONSE> handler, Controller.CustomSerDe<REQUEST> requestSerde, Controller.CustomSerDe<RESPONSE> responseSerde)
void	setEndpoint(CoordinationProtos.DrillbitEndpoint endpoint)

Methods inherited from class java.lang.Object

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

Constructor Detail

CustomHandlerRegistry

public CustomHandlerRegistry()

Method Detail

setEndpoint

public void setEndpoint(CoordinationProtos.DrillbitEndpoint endpoint)

registerCustomHandler

public <REQUEST,RESPONSE> void registerCustomHandler(int messageTypeId,
                                                     Controller.CustomMessageHandler<REQUEST,RESPONSE> handler,
                                                     Controller.CustomSerDe<REQUEST> requestSerde,
                                                     Controller.CustomSerDe<RESPONSE> responseSerde)

handle

public Response handle(BitControl.CustomMessage message,
                       DrillBuf dBody)
                throws RpcException

Throws:

RpcException