Package org.apache.drill.exec.server.rest

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

Modifier and Type	Field	Description
protected WebSessionResources	webSessionResources

Fields inherited from class org.apache.drill.exec.rpc.AbstractDisposableUserClientConnection

error, latch, queryState

Constructor Summary

Constructors

Constructor	Description
BaseWebUserConnection(WebSessionResources webSessionResources)

Method Summary

Modifier and Type	Method	Description
io.netty.util.concurrent.Future<Void>	getClosureFuture()	Returns the Future which will be notified when this channel is closed.
SocketAddress	getRemoteAddress()
UserSession	getSession()
WebSessionResources	resources()
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

protected WebSessionResources webSessionResources

Constructor Details

BaseWebUserConnection

public BaseWebUserConnection(WebSessionResources webSessionResources)

Method Details

getSession

public UserSession getSession()

Specified by:

getSession in interface UserClientConnection

Returns:

User session object.

getClosureFuture

public io.netty.util.concurrent.Future<Void> getClosureFuture()

Description copied from interface: UserClientConnection

Returns the Future which will be notified when this channel is closed. This method always returns the same future instance.

Specified by:

getClosureFuture in interface UserClientConnection

getRemoteAddress

public SocketAddress getRemoteAddress()

Specified by:

getRemoteAddress in interface UserClientConnection

Returns:

Return the client node address.

setAutoRead

public void setAutoRead(boolean enableAutoRead)

Specified by:

setAutoRead in interface ConnectionThrottle

resources

public WebSessionResources resources()

webDataType

protected String webDataType(TypeProtos.MajorType majorType)