public class ControlMessageHandler extends Object implements RequestHandler<ControlConnection>
Constructor and Description |
---|
ControlMessageHandler(WorkManager.WorkerBee bee) |
public ControlMessageHandler(WorkManager.WorkerBee bee)
public void handle(ControlConnection connection, int rpcType, io.netty.buffer.ByteBuf pBody, io.netty.buffer.ByteBuf dBody, ResponseSender sender) throws RpcException
RequestHandler
send
the response
+ throw UserRpcException, in which case a response will be sent using send
+ throw an Exception, in which case, the connection will be droppedhandle
in interface RequestHandler<ControlConnection>
connection
- remote connectionrpcType
- rpc typepBody
- messagedBody
- data, maybe nullsender
- used to send
the responseRpcException
public void startNewFragment(BitControl.PlanFragment fragment, DrillbitContext drillbitContext) throws UserRpcException
fragment
- UserRpcException
public GeneralRPCProtos.Ack cancelFragment(ExecProtos.FragmentHandle handle)
public GeneralRPCProtos.Ack resumeFragment(ExecProtos.FragmentHandle handle)
public GeneralRPCProtos.Ack receivingFragmentFinished(BitControl.FinishedReceiver finishedReceiver)
public GeneralRPCProtos.Ack requestFragmentStatus(BitControl.FragmentStatus status)
public GeneralRPCProtos.Ack requestQueryCancel(UserBitShared.QueryId queryId)
public GeneralRPCProtos.Ack initializeFragment(BitControl.InitializeFragments fragments) throws RpcException
RpcException
public UserBitShared.QueryProfile requestQueryStatus(UserBitShared.QueryId queryId) throws RpcException
RpcException
public CustomHandlerRegistry getHandlerRegistry()
Copyright © 1970 The Apache Software Foundation. All rights reserved.