Uses of Interface
org.apache.drill.exec.rpc.ConnectionThrottle
Package
Description
Java client API for submitting queries and accepting result sets from a Drill
server.
-
Uses of ConnectionThrottle in org.apache.drill.exec.client
Modifier and TypeClassDescriptionclass
Thin wrapper around a UserClient that handles connect/close and transforms String into ByteBuf.Modifier and TypeMethodDescriptionvoid
LoggingResultsListener.dataArrived
(QueryDataBatch result, ConnectionThrottle throttle) -
Uses of ConnectionThrottle in org.apache.drill.exec.rpc
Modifier and TypeInterfaceDescriptioninterface
interface
interface
ServerConnection<S extends ServerConnection<S>>
Modifier and TypeClassDescriptionclass
class
class
AbstractServerConnection<S extends ServerConnection<S>>
-
Uses of ConnectionThrottle in org.apache.drill.exec.rpc.control
-
Uses of ConnectionThrottle in org.apache.drill.exec.rpc.data
-
Uses of ConnectionThrottle in org.apache.drill.exec.rpc.user
Modifier and TypeClassDescriptionclass
class
Represents a client connection accepted by Foreman Drillbit's UserServer from a DrillClient.Modifier and TypeMethodDescriptionvoid
QueryResultHandler.batchArrived
(ConnectionThrottle throttle, io.netty.buffer.ByteBuf pBody, io.netty.buffer.ByteBuf dBody) Maps internal low-level API protocol toUserResultsListener
-level API protocol.void
AwaitableUserResultsListener.dataArrived
(QueryDataBatch result, ConnectionThrottle throttle) void
BlockingResultsListener.dataArrived
(QueryDataBatch result, ConnectionThrottle throttle) void
UserResultsListener.dataArrived
(QueryDataBatch result, ConnectionThrottle throttle) AQueryData
message was received -
Uses of ConnectionThrottle in org.apache.drill.exec.server.rest
Modifier and TypeClassDescriptionclass
class
WebUserConnectionWrapper
which represents theUserClientConnection
between WebServer and Foreman, for the WebUser submitting the query.static class
-
Uses of ConnectionThrottle in org.apache.drill.exec.server.rest.stream
Modifier and TypeClassDescriptionclass
Stream the results of a query to a REST client as JSON, following the schema defined byQueryResult
to maintain backward compatibility.