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 Details

    • SendingAccountor

      public SendingAccountor()
  • Method Details

    • waitForSendComplete

      public void waitForSendComplete()