Package 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	Description
SendingAccountor()

Method Summary

Modifier and Type	Method	Description
void	waitForSendComplete()

Methods inherited from class java.lang.Object

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

Constructor Details

SendingAccountor

public SendingAccountor()

Method Details

waitForSendComplete

public void waitForSendComplete()