Package 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	Description
CustomHandlerRegistry()

Method Summary

Modifier and Type	Method	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 Details

CustomHandlerRegistry

public CustomHandlerRegistry()

Method Details

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