Package org.apache.drill.exec.ops

Class AccountingUserConnection

java.lang.Object

org.apache.drill.exec.ops.AccountingUserConnection

public class AccountingUserConnection
extends Object

Wrapper around a UserClientConnection that tracks the status of batches sent to User.

Constructor Summary

Constructors

Constructor	Description
AccountingUserConnection(UserClientConnection connection, SendingAccountor sendingAccountor, RpcOutcomeListener<GeneralRPCProtos.Ack> statusHandler)

Method Summary

Modifier and Type	Method	Description
void	sendData(QueryDataPackage data)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

AccountingUserConnection

public AccountingUserConnection(UserClientConnection connection,
 SendingAccountor sendingAccountor,
 RpcOutcomeListener<GeneralRPCProtos.Ack> statusHandler)

Method Details

sendData

public void sendData(QueryDataPackage data)