processing/src/main/java/org/apache/druid/query/groupby/epinephelinae/StreamingMergeSortedGrouper.java
/**
   * Initialize a new slot for a new grouping key.  This may be potentially blocked if the array is full until at least
   * one slot becomes available.
   */
Initialize a new slot for a new grouping key.  This may be potentially blocked if the array is full until at least
one slot becomes available.
Initialize a new slot for a new grouping key . This may be potentially blocked if the array is full until at least one slot becomes available .
private void initNewSlot(ByteBuffer newKey)
  {
    increaseWriteIndex();
    final int recordOffset = recordSize * curWriteIndex;
    buffer.position(recordOffset);
    buffer.put(newKey);
    for (int i = 0; i < aggregators.length; i++) {
      aggregators[i].init(buffer, recordOffset + aggregatorOffsets[i]);
    }
  }
private void initNewSlot ( ByteBuffer newKey ) { increaseWriteIndex ( ) ; final int recordOffset = recordSize * curWriteIndex ; buffer . position ( recordOffset ) ; buffer . put ( newKey ) ; for ( int i = 0 ; i < aggregators . length ; i ++ ) { aggregators [ i ] . init ( buffer , recordOffset + aggregatorOffsets [ i ] ) ; } }
Initialize a new slot for a new grouping key.
Initialize a new slot for a new grouping key .
// Wait if the array is full and increase curWriteIndex