Package org.apache.drill.exec.ops
Class SendingAccountor
java.lang.Object
org.apache.drill.exec.ops.SendingAccountor
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
-
Method Summary
-
Constructor Details
-
SendingAccountor
public SendingAccountor()
-
-
Method Details
-
waitForSendComplete
public void waitForSendComplete()
-