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.expr.fn.impl
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.store.excel
org.apache.drill.exec.store.hdf5
org.apache.drill.exec.store.httpd
org.apache.drill.exec.store.log
org.apache.drill.exec.store.mock	Defines a mock data source which generates dummy test data for use in testing.
org.apache.drill.exec.store.parquet
org.apache.drill.exec.store.syslog
org.apache.drill.exec.udfs
org.apache.drill.exec.work.batch
org.apache.drill.test	Provides a variety of test framework tools to simplify Drill unit tests and ad-hoc tests created while developing features.

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

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

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

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

Modifier and Type	Method and Description
void	DrillClient.connect() Connects the client to a Drillbit server
void	DrillClient.connect(Properties props) Start's a connection from client to server
void	DrillClient.connect(String 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.
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.
List<QueryDataBatch>	DrillClient.runQuery(UserBitShared.QueryType type, String plan) Submits a string based query plan for execution and returns the result batches.

Uses of RpcException in org.apache.drill.exec.expr.fn.impl

Methods in org.apache.drill.exec.expr.fn.impl that throw RpcException

Modifier and Type	Method and Description
void	TestTypeFns.testDrillTypeOf()
void	TestTypeFns.testModeOf()
void	TestTypeFns.testSqlTypeOf()
void	TestTypeFns.testTypeOf()

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 and Description
void	StatusHandler.failed(RpcException ex)
void	DataTunnelStatusHandler.failed(RpcException ex)

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

Constructor and 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 and Description
class	ChannelClosedException
class	NonTransientRpcException
class	UserRpcException

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

Modifier and Type	Method and 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 and Description
void	AbstractClientConnection.channelClosed(RpcException ex)
void	AbstractServerConnection.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	RemoteConnection.channelClosed(RpcException ex)
void	RpcOutcomeListener.failed(RpcException ex) Called when an error occurred while waiting for the RPC outcome.
void	BaseRpcOutcomeListener.failed(RpcException ex)

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

Modifier and Type	Method and Description
static <T> T	RpcBus.get(io.netty.buffer.ByteBuf pBody, com.google.protobuf.Parser<T> parser)
protected abstract com.google.protobuf.MessageLite	RpcBus.getResponseDefaultInstance(int rpcType)
protected abstract com.google.protobuf.MessageLite	BasicServer.getResponseDefaultInstance(int rpcType)
protected abstract void	RpcBus.handle(C connection, int rpcType, io.netty.buffer.ByteBuf pBody, io.netty.buffer.ByteBuf dBody, ResponseSender sender)
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	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 and Description
void	ControlConnection.channelClosed(RpcException ex)

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

Modifier and Type	Method and Description
DrillBuf	ControlTunnel.CustomFuture.getBuffer()
com.google.protobuf.MessageLite	ControlClient.getResponseDefaultInstance(int rpcType)
static com.google.protobuf.MessageLite	DefaultInstanceHandler.getResponseDefaultInstance(int rpcType)
com.google.protobuf.MessageLite	ControlServer.getResponseDefaultInstance(int rpcType)
Response	CustomHandlerRegistry.handle(BitControl.CustomMessage message, DrillBuf dBody)
protected void	ControlClient.handle(ControlConnection connection, int rpcType, io.netty.buffer.ByteBuf pBody, io.netty.buffer.ByteBuf dBody, ResponseSender sender)
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 and 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 and Description
void	AuthenticationOutcomeListener.failed(RpcException ex)

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

Modifier and Type	Method and 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 and Description
void	UserServer.BitToUserConnection.channelClosed(RpcException ex)

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

Modifier and Type	Method and 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	UserServer.getResponseDefaultInstance(int rpcType)
protected com.google.protobuf.MessageLite	UserClient.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.store.excel

Methods in org.apache.drill.exec.store.excel that throw RpcException

Modifier and Type	Method and Description
void	TestExcelFormat.testBlankRowsInFileQuery()
void	TestExcelFormat.testDefineColumnsQuery()
void	TestExcelFormat.testEmptySheetQuery() This tests to what happens if you attempt to query a completely empty sheet The result should be an empty data set.
void	TestExcelFormat.testExplicitAllQuery()
void	TestExcelFormat.testExplicitMetadataQuery()
void	TestExcelFormat.testExplicitNoFieldNamesQuery()
void	TestExcelFormat.testExplicitNonDefaultSheetQuery()
void	TestExcelFormat.testExplicitSomeQuery()
void	TestExcelFormat.testGetSheetNames()
void	TestExcelFormat.testLastRowQuery()
void	TestExcelFormat.testNonDefaultSheetQuery()
void	TestExcelFormat.testStarNoFieldNamesQuery()

Uses of RpcException in org.apache.drill.exec.store.hdf5

Methods in org.apache.drill.exec.store.hdf5 that throw RpcException

Modifier and Type	Method and Description
void	TestHDF5Format.testFlattenColumnQuery()

Uses of RpcException in org.apache.drill.exec.store.httpd

Methods in org.apache.drill.exec.store.httpd that throw RpcException

Modifier and Type	Method and Description
void	TestHTTPDLogReader.testDateEpochField()
void	TestHTTPDLogReader.testDateField()
void	TestHTTPDLogReaderUserAgent.testMultiFormatUserAgent()

Uses of RpcException in org.apache.drill.exec.store.log

Methods in org.apache.drill.exec.store.log that throw RpcException

Modifier and Type	Method and Description
void	TestLogReader.testCount()
void	TestLogReader.testDate()
void	TestLogReader.testExplicitProject()
void	TestLogReader.testFirewallSchema()
void	TestLogReader.testFull()
void	TestLogReader.testMissingColumns()
void	TestLogReader.testRaw()
void	TestLogReader.testRawNoSchema()
void	TestLogReader.testRawUMNoSchema()
void	TestLogReader.testSomeFieldsQueryNoSchema()
void	TestLogReader.testStarQueryNoSchema() Test log queries without a defined schema using select *
void	TestLogReader.testUMNoSchema()
void	TestLogReader.testWildcard()
void	TestLogReader.testWildcardLargeFile() Tests for no crashes; does not validate results, unfortunately.

Uses of RpcException in org.apache.drill.exec.store.mock

Methods in org.apache.drill.exec.store.mock that throw RpcException

Modifier and Type	Method and Description
void	TestMockPlugin.testBoolean()
void	TestMockPlugin.testDouble()
void	TestMockPlugin.testRowLimit()
void	TestMockPlugin.testSizeLimit() By default, the mock reader limits batch size to 10 MB.
void	TestMockPlugin.testVarChar()

Uses of RpcException in org.apache.drill.exec.store.parquet

Methods in org.apache.drill.exec.store.parquet that throw RpcException

Modifier and Type	Method and Description
void	ParquetResultListener.getResults()

Uses of RpcException in org.apache.drill.exec.store.syslog

Methods in org.apache.drill.exec.store.syslog that throw RpcException

Modifier and Type	Method and Description
void	TestSyslogFormat.testNonComplexFields()

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

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

Modifier and Type	Method and Description
void	TestComplexSchemaFunctions.testMapSchemaFunction()
void	TestComplexSchemaFunctions.testMapSchemaFunctionWithInnerMap()
void	TestComplexSchemaFunctions.testMapSchemaFunctionWithNull()

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 and 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)

Uses of RpcException in org.apache.drill.test

Methods in org.apache.drill.test that throw RpcException

Modifier and Type	Method and Description
static DrillClient	QueryTestUtil.createClient(DrillConfig drillConfig, RemoteServiceSet remoteServiceSet, int maxWidth, Properties props) Create a DrillClient that can be used to query a drill cluster.
List<QueryDataBatch>	QueryBuilder.results() Run the query and return a list of the result batches.
DirectRowSet	QueryBuilder.rowSet() Run the query and return the first non-empty batch as a DirectRowSet object that can be inspected directly by the code using a RowSetReader.
double	QueryBuilder.singletonDouble() Run the query that is expected to return (at least) one row with the only (or first) column returning a double value.
int	QueryBuilder.singletonInt() Run the query that is expected to return (at least) one row with the only (or first) column returning a int value.
long	QueryBuilder.singletonLong() Run the query that is expected to return (at least) one row with the only (or first) column returning a long value.
org.joda.time.Period	QueryBuilder.singletonPeriod() Run the query that is expected to return (at least) one row with the only (or first) column returning a Period value.
String	QueryBuilder.singletonString() Run the query that is expected to return (at least) one row with the only (or first) column returning a string value.
<T,V> T	QueryBuilder.vectorValue(String columnName, Class<V> vectorClass, QueryBuilder.VectorQueryReader<T,V> reader) Run the query which expect to return vector V representation of type T for the column columnName.

Constructors in org.apache.drill.test that throw RpcException

Constructor and Description
ClientFixture(ClientFixture.ClientBuilder builder)