Uses of Interface
org.apache.drill.exec.rpc.ConnectionThrottle
Packages that use 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
Classes in org.apache.drill.exec.client that implement ConnectionThrottleModifier and TypeClassDescriptionclass
Thin wrapper around a UserClient that handles connect/close and transforms String into ByteBuf.Methods in org.apache.drill.exec.client with parameters of type ConnectionThrottleModifier and TypeMethodDescriptionvoid
LoggingResultsListener.dataArrived
(QueryDataBatch result, ConnectionThrottle throttle) -
Uses of ConnectionThrottle in org.apache.drill.exec.rpc
Subinterfaces of ConnectionThrottle in org.apache.drill.exec.rpcModifier and TypeInterfaceDescriptioninterface
interface
interface
ServerConnection<S extends ServerConnection<S>>
Classes in org.apache.drill.exec.rpc that implement ConnectionThrottleModifier and TypeClassDescriptionclass
class
class
AbstractServerConnection<S extends ServerConnection<S>>
-
Uses of ConnectionThrottle in org.apache.drill.exec.rpc.control
Classes in org.apache.drill.exec.rpc.control that implement ConnectionThrottle -
Uses of ConnectionThrottle in org.apache.drill.exec.rpc.data
Classes in org.apache.drill.exec.rpc.data that implement ConnectionThrottle -
Uses of ConnectionThrottle in org.apache.drill.exec.rpc.user
Classes in org.apache.drill.exec.rpc.user that implement ConnectionThrottleModifier and TypeClassDescriptionclass
class
Represents a client connection accepted by Foreman Drillbit's UserServer from a DrillClient.Methods in org.apache.drill.exec.rpc.user with parameters of type ConnectionThrottleModifier 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
Classes in org.apache.drill.exec.server.rest that implement ConnectionThrottleModifier 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
Classes in org.apache.drill.exec.server.rest.stream that implement ConnectionThrottleModifier and TypeClassDescriptionclass
Stream the results of a query to a REST client as JSON, following the schema defined byQueryResult
to maintain backward compatibility.