processing/src/main/java/org/apache/druid/query/groupby/epinephelinae/StreamingMergeSortedGrouper.java
/**
   * Signal that no more inputs are added.  Must be called after {@link #aggregate(Object)} is called for the last input.
   */
Signal that no more inputs are added.  Must be called after  #aggregate(Object) is called for the last input.
Signal that no more inputs are added . Must be called after #aggregate ( Object ) is called for the last input .
public void finish()
  {
    increaseWriteIndex();
    finished = true;
  }
public void finish ( ) { increaseWriteIndex ( ) ; finished = true ; }
Signal that no more inputs are added.
Signal that no more inputs are added .
// Once finished is set, curWriteIndex must not be changed. This guarantees that the remaining number of items in // the array is always decreased as the reading thread proceeds. See hasNext() and remaining() below.