Uses of Class
org.apache.drill.exec.rpc.RpcException

Packages that use RpcException

Package	Description
org.apache.drill.exec.client	Java client API for submitting queries and accepting result sets from a Drill server.
org.apache.drill.exec.ops
org.apache.drill.exec.rpc
org.apache.drill.exec.rpc.control
org.apache.drill.exec.rpc.data
org.apache.drill.exec.rpc.security	Communication security.
org.apache.drill.exec.rpc.user
org.apache.drill.exec.work.batch

Uses of RpcException in org.apache.drill.exec.client

Subclasses of RpcException in org.apache.drill.exec.client

Modifier and Type	Class	Description
class	InvalidConnectionInfoException	Exception for malformed connection string from client

Methods in org.apache.drill.exec.client that throw RpcException

Modifier and Type	Method	Description
void	DrillClient.connect()	Connects the client to a Drillbit server
void	DrillClient.connect(String connect, Properties props)	Start's a connection from client to server
void	DrillClient.connect(Properties props)	Start's a connection from client to server
List<QueryDataBatch>	DrillClient.executePreparedStatement(UserProtos.PreparedStatementHandle preparedStatementHandle)	Execute the given prepared statement and return the results.
List<QueryDataBatch>	DrillClient.runQuery(UserBitShared.QueryType type, String plan)	Submits a string based query plan for execution and returns the result batches.
void	DrillClient.runQuery(UserBitShared.QueryType type, List<BitControl.PlanFragment> planFragments, UserResultsListener resultsListener)	Run query based on list of fragments that were supposedly produced during query planning phase.

Uses of RpcException in org.apache.drill.exec.ops

Methods in org.apache.drill.exec.ops with parameters of type RpcException

Modifier and Type	Method	Description
void	DataTunnelStatusHandler.failed(RpcException ex)
void	StatusHandler.failed(RpcException ex)

Constructor parameters in org.apache.drill.exec.ops with type arguments of type RpcException

Modifier	Constructor	Description
	DataTunnelStatusHandler(Consumer<RpcException> consumer, SendingAccountor sendingAccountor)
	StatusHandler(Consumer<RpcException> consumer, SendingAccountor sendingAccountor)

Uses of RpcException in org.apache.drill.exec.rpc

Subclasses of RpcException in org.apache.drill.exec.rpc

Modifier and Type	Class	Description
class	ChannelClosedException
class	NonTransientRpcException
class	UserRpcException

Methods in org.apache.drill.exec.rpc that return RpcException

Modifier and Type	Method	Description
protected RpcException	RpcCheckedFuture.mapException(Exception e)
static RpcException	RpcException.mapException(String message, Throwable t)
static RpcException	RpcException.mapException(Throwable t)

Methods in org.apache.drill.exec.rpc with parameters of type RpcException

Modifier and Type	Method	Description
void	AbstractClientConnection.channelClosed(RpcException ex)
void	AbstractRemoteConnection.channelClosed(RpcException ex)	Called from the RpcBus's channel close handler to close all remaining resources associated with this connection.
void	AbstractServerConnection.channelClosed(RpcException ex)
void	RemoteConnection.channelClosed(RpcException ex)
void	BaseRpcOutcomeListener.failed(RpcException ex)
void	RpcOutcomeListener.failed(RpcException ex)	Called when an error occurred while waiting for the RPC outcome.

Methods in org.apache.drill.exec.rpc that throw RpcException

Modifier and Type	Method	Description
static <T> T	RpcBus.get(io.netty.buffer.ByteBuf pBody, com.google.protobuf.Parser<T> parser)
protected abstract com.google.protobuf.MessageLite	BasicServer.getResponseDefaultInstance(int rpcType)
protected abstract com.google.protobuf.MessageLite	RpcBus.getResponseDefaultInstance(int rpcType)
protected void	BasicServer.handle(SC connection, int rpcType, io.netty.buffer.ByteBuf pBody, io.netty.buffer.ByteBuf dBody, ResponseSender sender)
void	FailingRequestHandler.handle(S connection, int rpcType, io.netty.buffer.ByteBuf pBody, io.netty.buffer.ByteBuf dBody, ResponseSender sender)
void	RequestHandler.handle(S connection, int rpcType, io.netty.buffer.ByteBuf pBody, io.netty.buffer.ByteBuf dBody, ResponseSender sender)	Handle request of given type (rpcType) with message (pBody) and optional data (dBody) on the connection, and return the appropriate response.
protected abstract void	RpcBus.handle(C connection, int rpcType, io.netty.buffer.ByteBuf pBody, io.netty.buffer.ByteBuf dBody, ResponseSender sender)
protected abstract void	BasicClient.prepareSaslHandshake(RpcConnectionHandler<CC> connectionHandler, List<String> serverAuthMechanisms)	Creates various instances needed to start the SASL handshake.
protected abstract List<String>	BasicClient.validateHandshake(HR validateHandshake)
static List<String>	BitRpcUtility.validateHandshake(int handshakeRpcVersion, List<String> remoteAuthMechs, int rpcVersion, ClientConnection connection, BitConnectionConfig config, BasicClient client)	Method to do validation on the handshake message received from server side.

Uses of RpcException in org.apache.drill.exec.rpc.control

Methods in org.apache.drill.exec.rpc.control with parameters of type RpcException

Modifier and Type	Method	Description
void	ControlConnection.channelClosed(RpcException ex)

Methods in org.apache.drill.exec.rpc.control that throw RpcException

Modifier and Type	Method	Description
DrillBuf	ControlTunnel.CustomFuture.getBuffer()
com.google.protobuf.MessageLite	ControlClient.getResponseDefaultInstance(int rpcType)
com.google.protobuf.MessageLite	ControlServer.getResponseDefaultInstance(int rpcType)
static com.google.protobuf.MessageLite	DefaultInstanceHandler.getResponseDefaultInstance(int rpcType)
protected void	ControlClient.handle(ControlConnection connection, int rpcType, io.netty.buffer.ByteBuf pBody, io.netty.buffer.ByteBuf dBody, ResponseSender sender)
Response	CustomHandlerRegistry.handle(BitControl.CustomMessage message, DrillBuf dBody)
protected List<String>	ControlClient.validateHandshake(BitControl.BitControlHandshake handshake)

Uses of RpcException in org.apache.drill.exec.rpc.data

Methods in org.apache.drill.exec.rpc.data that throw RpcException

Modifier and Type	Method	Description
com.google.protobuf.MessageLite	DataClient.getResponseDefaultInstance(int rpcType)
com.google.protobuf.MessageLite	DataServer.getResponseDefaultInstance(int rpcType)
static com.google.protobuf.MessageLite	DataDefaultInstanceHandler.getResponseDefaultInstanceClient(int rpcType)
static com.google.protobuf.MessageLite	DataDefaultInstanceHandler.getResponseDefaultInstanceServer(int rpcType)
protected void	DataClient.handle(DataClientConnection connection, int rpcType, io.netty.buffer.ByteBuf pBody, io.netty.buffer.ByteBuf dBody, ResponseSender sender)
protected List<String>	DataClient.validateHandshake(BitData.BitServerHandshake handshake)

Uses of RpcException in org.apache.drill.exec.rpc.security

Methods in org.apache.drill.exec.rpc.security with parameters of type RpcException

Modifier and Type	Method	Description
void	AuthenticationOutcomeListener.failed(RpcException ex)

Methods in org.apache.drill.exec.rpc.security that throw RpcException

Modifier and Type	Method	Description
void	ServerAuthenticationHandler.handle(S connection, int rpcType, io.netty.buffer.ByteBuf pBody, io.netty.buffer.ByteBuf dBody, ResponseSender sender)

Uses of RpcException in org.apache.drill.exec.rpc.user

Methods in org.apache.drill.exec.rpc.user with parameters of type RpcException

Modifier and Type	Method	Description
void	UserServer.BitToUserConnection.channelClosed(RpcException ex)

Methods in org.apache.drill.exec.rpc.user that throw RpcException

Modifier and Type	Method	Description
void	QueryResultHandler.batchArrived(ConnectionThrottle throttle, io.netty.buffer.ByteBuf pBody, io.netty.buffer.ByteBuf dBody)	Maps internal low-level API protocol to UserResultsListener-level API protocol.
void	UserClient.connect(CoordinationProtos.DrillbitEndpoint endpoint, DrillProperties properties, UserBitShared.UserCredentials credentials)	Connects, and if required, authenticates.
protected com.google.protobuf.MessageLite	UserClient.getResponseDefaultInstance(int rpcType)
protected com.google.protobuf.MessageLite	UserServer.getResponseDefaultInstance(int rpcType)
protected void	UserClient.handle(UserClient.UserToBitConnection connection, int rpcType, io.netty.buffer.ByteBuf pBody, io.netty.buffer.ByteBuf dBody, ResponseSender sender)
void	QueryResultHandler.resultArrived(io.netty.buffer.ByteBuf pBody)	Maps internal low-level API protocol to UserResultsListener-level API protocol.
protected List<String>	UserClient.validateHandshake(UserProtos.BitToUserHandshake inbound)

Uses of RpcException in org.apache.drill.exec.work.batch

Methods in org.apache.drill.exec.work.batch that throw RpcException

Modifier and Type	Method	Description
void	ControlMessageHandler.handle(ControlConnection connection, int rpcType, io.netty.buffer.ByteBuf pBody, io.netty.buffer.ByteBuf dBody, ResponseSender sender)
GeneralRPCProtos.Ack	ControlMessageHandler.initializeFragment(BitControl.InitializeFragments fragments)
UserBitShared.QueryProfile	ControlMessageHandler.requestQueryStatus(UserBitShared.QueryId queryId)