Class BaseWebUserConnection
java.lang.Object
org.apache.drill.exec.rpc.AbstractDisposableUserClientConnection
org.apache.drill.exec.server.rest.BaseWebUserConnection
- All Implemented Interfaces:
ConnectionThrottle
,UserClientConnection
- Direct Known Subclasses:
StreamingHttpConnection
,WebUserConnection
public abstract class BaseWebUserConnection
extends AbstractDisposableUserClientConnection
implements ConnectionThrottle
-
Field Summary
Fields inherited from class org.apache.drill.exec.rpc.AbstractDisposableUserClientConnection
error, latch, queryState
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionio.netty.util.concurrent.Future<Void>
Returns theFuture
which will be notified when this channel is closed.void
setAutoRead
(boolean enableAutoRead) protected String
webDataType
(TypeProtos.MajorType majorType) Methods inherited from class org.apache.drill.exec.rpc.AbstractDisposableUserClientConnection
await, await, getError, getQueryState, sendResult
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.apache.drill.exec.rpc.UserClientConnection
sendData
-
Field Details
-
webSessionResources
-
-
Constructor Details
-
BaseWebUserConnection
-
-
Method Details
-
getSession
- Specified by:
getSession
in interfaceUserClientConnection
- Returns:
- User session object.
-
getClosureFuture
Description copied from interface:UserClientConnection
Returns theFuture
which will be notified when this channel is closed. This method always returns the same future instance.- Specified by:
getClosureFuture
in interfaceUserClientConnection
-
getRemoteAddress
- Specified by:
getRemoteAddress
in interfaceUserClientConnection
- Returns:
- Return the client node address.
-
setAutoRead
public void setAutoRead(boolean enableAutoRead) - Specified by:
setAutoRead
in interfaceConnectionThrottle
-
resources
-
webDataType
-