Method create

bolt/exec/WindowFunction.cpp:83–122

}

std::unique_ptr<WindowFunction> WindowFunction::create(
    const std::string& name,
    const std::vector<WindowFunctionArg>& args,
    const TypePtr& resultType,
    bool ignoreNulls,
    memory::MemoryPool* pool,
    HashStringAllocator* stringAllocator,
    const core::QueryConfig& config) {
  // Lookup the function in the new registry first.
  if (auto func = getWindowFunctionEntry(name)) {
    std::vector<TypePtr> argTypes;
    argTypes.reserve(args.size());
    for (const auto& arg : args) {
      argTypes.push_back(arg.type);
    }

    const auto& signatures = func.value()->signatures;
    for (auto& signature : signatures) {
      SignatureBinder binder(*signature, argTypes);
      if (binder.tryBind()) {
        auto type = binder.tryResolveType(signature->returnType());
        BOLT_USER_CHECK(
            type->equivalent(*resultType),
            "Unexpected return type for window function {}. Expected {}. Got {}.",
            toString(name, argTypes),
            type->toString(),
            resultType->toString())
        return func.value()->factory(
            args, resultType, ignoreNulls, pool, stringAllocator, config);
      }
    }

    BOLT_USER_FAIL(
        "Window function signature is not supported: {}. Supported signatures: {}.",
        toString(name, argTypes),
        toString(signatures));
  }

  BOLT_USER_FAIL("Window function not registered: {}", name);
}

void WindowFunction::setEmptyFramesResult(
    const SelectivityVector& validRows,