Method noMoreInput

bolt/exec/Window.cpp:520–529

}

void Window::noMoreInput() {
  MicrosecondTimer timer(&addInputTimeUs_);
  Operator::noMoreInput();
  auto maxOutputRows = outputBatchRows(windowBuild_->estimateOutputRowSize());
  windowBuild_->setMaxOutputRows(maxOutputRows);
  if (needSort_) {
    windowBuild_->noMoreInputCommon();
  }
  windowBuild_->noMoreInput();
}

void Window::callResetPartition() {
  MicrosecondTimer timer(&extractColumnTimeUs_);