Method noMoreInput

bolt/exec/SortWindowBuild.cpp:229–258

}

void SortWindowBuild::noMoreInput() {
  if (numRows_ == 0) {
    return;
  }

  if (sortSpiller_ != nullptr) {
    finishLoadFromSpill_ = false;
    return;

  } else {
    // At this point we have seen all the input rows which are sorted. This will
    // compute the index for each partition.
    computePartitionStartRows();
    clearTopRows();
  }
}

void SortWindowBuild::finish() {
  for (int i = 0; i < allocatedSizes_.size(); i++) {
    if (allocatedSizes_[i] == 0) {
      continue;
    }
    data_->pool()->free(allocatedStarts_[i], allocatedSizes_[i]);
    allocatedSizes_[i] = 0;
  }
  sortRows_.clear();
  allocatedStarts_.clear();
  allocatedSizes_.clear();
  numBuffers_.clear();
  data_->clear();
  data_->pool()->release();
}