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 and Description
AccountingUserConnection(UserClientConnection connection, SendingAccountor sendingAccountor, RpcOutcomeListener<GeneralRPCProtos.Ack> statusHandler)

Method Summary

Modifier and Type	Method and Description
void	sendData(QueryDataPackage data)

Methods inherited from class java.lang.Object

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

Constructor Detail

AccountingUserConnection

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

Method Detail

sendData

public void sendData(QueryDataPackage data)