Package org.apache.drill.exec.rpc.control

Class ControlTunnel

java.lang.Object

org.apache.drill.exec.rpc.control.ControlTunnel

public class ControlTunnel
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ControlTunnel.CancelQuery
class	ControlTunnel.CustomFuture<RECEIVE>	A class used to return a synchronous future when doing custom rpc messages.
static class	ControlTunnel.CustomMessageSender
class	ControlTunnel.CustomTunnel<SEND,RECEIVE>	A special tunnel that can be used for custom types of messages.
static class	ControlTunnel.JacksonSerDe<MSG>
static class	ControlTunnel.ProtoSerDe<MSG extends com.google.protobuf.MessageLite>
static class	ControlTunnel.ReceiverFinished
static class	ControlTunnel.RequestProfile
static class	ControlTunnel.SendFragment
static class	ControlTunnel.SendFragmentStatus
static class	ControlTunnel.SignalFragment
static class	ControlTunnel.SyncCustomMessageSender

Constructor Summary

Constructors

Constructor	Description
ControlTunnel(ControlConnectionManager manager)

Method Summary

Modifier and Type	Method	Description
void	cancelFragment(RpcOutcomeListener<GeneralRPCProtos.Ack> outcomeListener, ExecProtos.FragmentHandle handle)
<SEND extends com.google.protobuf.MessageLite, RECEIVE extends com.google.protobuf.MessageLite> ControlTunnel.CustomTunnel<SEND,RECEIVE>	getCustomTunnel(int messageTypeId, Class<SEND> clazz, com.google.protobuf.Parser<RECEIVE> parser)
<SEND, RECEIVE> ControlTunnel.CustomTunnel<SEND,RECEIVE>	getCustomTunnel(int messageTypeId, Controller.CustomSerDe<SEND> send, Controller.CustomSerDe<RECEIVE> receive)
void	informReceiverFinished(RpcOutcomeListener<GeneralRPCProtos.Ack> outcomeListener, BitControl.FinishedReceiver finishedReceiver)
DrillRpcFuture<GeneralRPCProtos.Ack>	requestCancelQuery(UserBitShared.QueryId queryId)
DrillRpcFuture<UserBitShared.QueryProfile>	requestQueryProfile(UserBitShared.QueryId queryId)
void	sendFragments(RpcOutcomeListener<GeneralRPCProtos.Ack> outcomeListener, BitControl.InitializeFragments fragments)
DrillRpcFuture<GeneralRPCProtos.Ack>	sendFragmentStatus(BitControl.FragmentStatus status)
void	unpauseFragment(RpcOutcomeListener<GeneralRPCProtos.Ack> outcomeListener, ExecProtos.FragmentHandle handle)

Methods inherited from class java.lang.Object

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

Constructor Details

ControlTunnel

public ControlTunnel(ControlConnectionManager manager)

Method Details

sendFragments

public void sendFragments(RpcOutcomeListener<GeneralRPCProtos.Ack> outcomeListener,
 BitControl.InitializeFragments fragments)

cancelFragment

public void cancelFragment(RpcOutcomeListener<GeneralRPCProtos.Ack> outcomeListener,
 ExecProtos.FragmentHandle handle)

unpauseFragment

public void unpauseFragment(RpcOutcomeListener<GeneralRPCProtos.Ack> outcomeListener,
 ExecProtos.FragmentHandle handle)

requestCancelQuery

public DrillRpcFuture<GeneralRPCProtos.Ack> requestCancelQuery(UserBitShared.QueryId queryId)

informReceiverFinished

public void informReceiverFinished(RpcOutcomeListener<GeneralRPCProtos.Ack> outcomeListener,
 BitControl.FinishedReceiver finishedReceiver)

sendFragmentStatus

public DrillRpcFuture<GeneralRPCProtos.Ack> sendFragmentStatus(BitControl.FragmentStatus status)

requestQueryProfile

public DrillRpcFuture<UserBitShared.QueryProfile> requestQueryProfile(UserBitShared.QueryId queryId)

getCustomTunnel

public <SEND extends com.google.protobuf.MessageLite,
RECEIVE extends com.google.protobuf.MessageLite>
ControlTunnel.CustomTunnel<SEND,RECEIVE> getCustomTunnel(int messageTypeId,
 Class<SEND> clazz,
 com.google.protobuf.Parser<RECEIVE> parser)

getCustomTunnel

public <SEND,
RECEIVE>
ControlTunnel.CustomTunnel<SEND,RECEIVE> getCustomTunnel(int messageTypeId,
 Controller.CustomSerDe<SEND> send,
 Controller.CustomSerDe<RECEIVE> receive)