org.apache.drill.exec.ops

Class SendingAccountor

java.lang.Object

org.apache.drill.exec.ops.SendingAccountor

public class SendingAccountor
extends Object

Account for whether all messages sent have been completed. Necessary before finishing a task so we don't think buffers are hanging when they will be released. TODO: Need to update to use long for number of pending messages.

Constructor Summary

Constructors

Constructor and Description
SendingAccountor()

Method Summary

Modifier and Type	Method and Description
void	waitForSendComplete()

Methods inherited from class java.lang.Object

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

Constructor Detail

SendingAccountor

public SendingAccountor()

Method Detail

waitForSendComplete

public void waitForSendComplete()