Method createWindowFunctions

bolt/exec/Window.cpp:338–370

}

void Window::createWindowFunctions() {
  BOLT_CHECK_NOT_NULL(windowNode_);
  BOLT_CHECK(windowFunctions_.empty());
  BOLT_CHECK(windowFrames_.empty());

  const auto& inputType = windowNode_->sources()[0]->outputType();
  for (const auto& windowNodeFunction : windowNode_->windowFunctions()) {
    std::vector<WindowFunctionArg> functionArgs;
    functionArgs.reserve(windowNodeFunction.functionCall->inputs().size());
    for (auto& arg : windowNodeFunction.functionCall->inputs()) {
      auto channel = exprToChannel(arg.get(), inputType);
      if (channel == kConstantChannel) {
        auto constantArg = core::TypedExprs::asConstant(arg);
        functionArgs.push_back(
            {arg->type(), constantArg->toConstantVector(pool()), std::nullopt});
      } else {
        functionArgs.push_back({arg->type(), nullptr, channel});
      }
    }

    windowFunctions_.push_back(WindowFunction::create(
        windowNodeFunction.functionCall->name(),
        functionArgs,
        windowNodeFunction.functionCall->type(),
        windowNodeFunction.ignoreNulls,
        operatorCtx_->pool(),
        &stringAllocator_,
        operatorCtx_->driverCtx()->queryConfig()));

    windowFrames_.push_back(
        createWindowFrame(windowNode_, windowNodeFunction.frame, inputType));
  }
}

void Window::createWindowFunctionsForSpillableWindowBuild() {
  const auto& inputType = windowNode_->sources()[0]->outputType();