Package org.apache.drill.exec.rpc

Class AbstractDisposableUserClientConnection

java.lang.Object

org.apache.drill.exec.rpc.AbstractDisposableUserClientConnection

All Implemented Interfaces:

UserClientConnection

Direct Known Subclasses:

BaseWebUserConnection

public abstract class AbstractDisposableUserClientConnection
extends Object
implements UserClientConnection

Helps to run a query and await on the results. All the inheriting sub-class manages the session/connection state and submits query with respect to that state. The subclass instance lifetime is per query lifetime and is not re-used.

Field Summary

Fields

Modifier and Type	Field	Description
protected UserBitShared.DrillPBError	error
protected final CountDownLatch	latch
protected String	queryState

Constructor Summary

Constructors

Constructor	Description
AbstractDisposableUserClientConnection()

Method Summary

Modifier and Type	Method	Description
void	await()	Wait indefinitely until the query is completed.
boolean	await(long timeoutMillis)	Wait until the query has completed or timeout is passed.
UserBitShared.DrillPBError	getError()
String	getQueryState()
void	sendResult(RpcOutcomeListener<GeneralRPCProtos.Ack> listener, UserBitShared.QueryResult result)	Send query result outcome to client.

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

getClosureFuture, getRemoteAddress, getSession, sendData

Field Details

latch

protected final CountDownLatch latch

error

protected volatile UserBitShared.DrillPBError error

queryState

protected String queryState

Constructor Details

AbstractDisposableUserClientConnection

public AbstractDisposableUserClientConnection()

Method Details

await

public boolean await(long timeoutMillis)
              throws InterruptedException

Wait until the query has completed or timeout is passed.

Throws:

InterruptedException

await

public void await()
           throws Exception

Wait indefinitely until the query is completed. Used only in case of WebUser

Throws:

Exception

sendResult

public void sendResult(RpcOutcomeListener<GeneralRPCProtos.Ack> listener,
 UserBitShared.QueryResult result)

Description copied from interface: UserClientConnection

Send query result outcome to client. Outcome is returned through listener.

Specified by:

sendResult in interface UserClientConnection

Parameters:

listener - The listener

result - The query result to be sent

getError

public UserBitShared.DrillPBError getError()

Returns:

Any error returned in query execution.

getQueryState

public String getQueryState()