ExtensionFunctionsWhitelist.cpp

Go to the documentation of this file.

/*
 * Copyright 2022 HEAVY.AI, Inc.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

#include "QueryEngine/ExtensionFunctionsWhitelist.h"

#include <boost/algorithm/string/join.hpp>
#include <iostream>

#include "QueryEngine/ExtensionFunctionsBinding.h"
#include "QueryEngine/JsonAccessors.h"
#include "QueryEngine/TableFunctions/TableFunctionsFactory.h"
#include "Shared/StringTransform.h"

// Get the list of all type specializations for the given function name.
std::vector<ExtensionFunction>* ExtensionFunctionsWhitelist::get(
    const std::string& name) {
  const auto it = functions_.find(to_upper(name));
  if (it == functions_.end()) {
    return nullptr;
  }
  return &it->second;
}

std::vector<ExtensionFunction>* ExtensionFunctionsWhitelist::get_udf(
    const std::string& name) {
  const auto it = udf_functions_.find(to_upper(name));
  if (it == udf_functions_.end()) {
    return nullptr;
  }
  return &it->second;
}

// Get the list of all udfs
std::unordered_set<std::string> ExtensionFunctionsWhitelist::get_udfs_name(
    const bool is_runtime) {
  std::unordered_set<std::string> names;
  const auto collections = {&functions_, &udf_functions_, &rt_udf_functions_};
  for (auto funcs : collections) {
    for (auto& pair : *funcs) {
      ExtensionFunction udf = pair.second.at(0);
      if (udf.isRuntime() == is_runtime) {
        names.insert(udf.getName(/* keep_suffix */ false));
      }
    }
  }
  return names;
}

std::vector<ExtensionFunction> ExtensionFunctionsWhitelist::get_ext_funcs(
    const std::string& name) {
  std::vector<ExtensionFunction> ext_funcs = {};
  const auto collections = {&functions_, &udf_functions_, &rt_udf_functions_};
  const auto uname = to_upper(name);
  for (auto funcs : collections) {
    const auto it = funcs->find(uname);
    if (it == funcs->end()) {
      continue;
    }
    auto ext_func_sigs = it->second;
    std::copy(ext_func_sigs.begin(), ext_func_sigs.end(), std::back_inserter(ext_funcs));
  }
  return ext_funcs;
}

std::vector<ExtensionFunction> ExtensionFunctionsWhitelist::get_ext_funcs(
    const std::string& name,
    const bool is_gpu) {
  std::vector<ExtensionFunction> ext_funcs = {};
  const auto collections = {&functions_, &udf_functions_, &rt_udf_functions_};
  const auto uname = to_upper(name);
  for (auto funcs : collections) {
    const auto it = funcs->find(uname);
    if (it == funcs->end()) {
      continue;
    }
    auto ext_func_sigs = it->second;
    std::copy_if(ext_func_sigs.begin(),
                 ext_func_sigs.end(),
                 std::back_inserter(ext_funcs),
                 [is_gpu](auto sig) { return (is_gpu ? sig.isGPU() : sig.isCPU()); });
  }
  return ext_funcs;
}

std::vector<ExtensionFunction> ExtensionFunctionsWhitelist::get_ext_funcs(
    const std::string& name,
    size_t arity) {
  std::vector<ExtensionFunction> ext_funcs = {};
  const auto collections = {&functions_, &udf_functions_, &rt_udf_functions_};
  const auto uname = to_upper(name);
  for (auto funcs : collections) {
    const auto it = funcs->find(uname);
    if (it == funcs->end()) {
      continue;
    }
    auto ext_func_sigs = it->second;
    std::copy_if(ext_func_sigs.begin(),
                 ext_func_sigs.end(),
                 std::back_inserter(ext_funcs),
                 [arity](auto sig) { return arity == sig.getInputArgs().size(); });
  }
  return ext_funcs;
}

std::vector<ExtensionFunction> ExtensionFunctionsWhitelist::get_ext_funcs(
    const std::string& name,
    size_t arity,
    const SQLTypeInfo& rtype) {
  std::vector<ExtensionFunction> ext_funcs = {};
  const auto collections = {&functions_, &udf_functions_, &rt_udf_functions_};
  const auto uname = to_upper(name);
  for (auto funcs : collections) {
    const auto it = funcs->find(uname);
    if (it == funcs->end()) {
      continue;
    }
    auto ext_func_sigs = it->second;
    std::copy_if(ext_func_sigs.begin(),
                 ext_func_sigs.end(),
                 std::back_inserter(ext_funcs),
                 [arity, rtype](auto sig) {
                   // Ideally, arity should be equal to the number of
                   // sig arguments but there seems to be many cases
                   // where some sig arguments will be represented
                   // with multiple arguments, for instance, array
                   // argument is translated to data pointer and array
                   // size arguments.
                   if (arity > sig.getInputArgs().size()) {
                     return false;
                   }
                   auto rt = rtype.get_type();
                   auto st = ext_arg_type_to_type_info(sig.getRet()).get_type();
                   return (st == rt || (st == kTINYINT && rt == kBOOLEAN));
                 });
  }
  return ext_funcs;
}

namespace {

// Returns the LLVM name for `type`.
std::string serialize_type(const ExtArgumentType type,
                           bool byval = true,
                           bool declare = false) {
  switch (type) {
    case ExtArgumentType::Bool:
      return "i8";  // clang converts bool to i8
    case ExtArgumentType::Int8:
      return "i8";
    case ExtArgumentType::Int16:
      return "i16";
    case ExtArgumentType::Int32:
      return "i32";
    case ExtArgumentType::Int64:
      return "i64";
    case ExtArgumentType::Float:
      return "float";
    case ExtArgumentType::Double:
      return "double";
    case ExtArgumentType::Void:
      return "void";
    case ExtArgumentType::PInt8:
      return "i8*";
    case ExtArgumentType::PInt16:
      return "i16*";
    case ExtArgumentType::PInt32:
      return "i32*";
    case ExtArgumentType::PInt64:
      return "i64*";
    case ExtArgumentType::PFloat:
      return "float*";
    case ExtArgumentType::PDouble:
      return "double*";
    case ExtArgumentType::PBool:
      return "i1*";
    case ExtArgumentType::ArrayInt8:
      return (declare ? "{i8*, i64, i8}*" : "Array<i8>");
    case ExtArgumentType::ArrayInt16:
      return (declare ? "{i16*, i64, i8}*" : "Array<i16>");
    case ExtArgumentType::ArrayInt32:
      return (declare ? "{i32*, i64, i8}*" : "Array<i32>");
    case ExtArgumentType::ArrayInt64:
      return (declare ? "{i64*, i64, i8}*" : "Array<i64>");
    case ExtArgumentType::ArrayFloat:
      return (declare ? "{float*, i64, i8}*" : "Array<float>");
    case ExtArgumentType::ArrayDouble:
      return (declare ? "{double*, i64, i8}*" : "Array<double>");
    case ExtArgumentType::ArrayBool:
      return (declare ? "{i1*, i64, i8}*" : "Array<i1>");
    case ExtArgumentType::ArrayTextEncodingDict:
      return (declare ? "{i32*, i64, i8}*" : "Array<TextEncodingDict>");
    case ExtArgumentType::GeoPoint:
      return "geo_point";
    case ExtArgumentType::GeoMultiPoint:
      return "geo_multi_point";
    case ExtArgumentType::GeoLineString:
      return "geo_linestring";
    case ExtArgumentType::GeoMultiLineString:
      return "geo_multi_linestring";
    case ExtArgumentType::GeoPolygon:
      return "geo_polygon";
    case ExtArgumentType::GeoMultiPolygon:
      return "geo_multi_polygon";
    case ExtArgumentType::Cursor:
      return "cursor";
    case ExtArgumentType::ColumnInt8:
      return (declare ? (byval ? "{i8*, i64}" : "i8*") : "Column<i8>");
    case ExtArgumentType::ColumnInt16:
      return (declare ? (byval ? "{i16*, i64}" : "i8*") : "Column<i16>");
    case ExtArgumentType::ColumnInt32:
      return (declare ? (byval ? "{i32*, i64}" : "i8*") : "Column<i32>");
    case ExtArgumentType::ColumnInt64:
      return (declare ? (byval ? "{i64*, i64}" : "i8*") : "Column<i64>");
    case ExtArgumentType::ColumnFloat:
      return (declare ? (byval ? "{float*, i64}" : "i8*") : "Column<float>");
    case ExtArgumentType::ColumnDouble:
      return (declare ? (byval ? "{double*, i64}" : "i8*") : "Column<double>");
    case ExtArgumentType::ColumnBool:
      return (declare ? (byval ? "{i8*, i64}" : "i8*") : "Column<bool>");
    case ExtArgumentType::ColumnTextEncodingDict:
      return (declare ? (byval ? "{i32*, i64}" : "i8*") : "Column<TextEncodingDict>");
    case ExtArgumentType::ColumnTimestamp:
      return (declare ? (byval ? "{i64*, i64}" : "i8*") : "Column<timestamp>");
    case ExtArgumentType::TextEncodingNone:
      return (declare ? (byval ? "{i8*, i64}" : "i8*") : "TextEncodingNone");
    case ExtArgumentType::TextEncodingDict:
      return (declare ? "{i8*, i32}*" : "TextEncodingDict");
    case ExtArgumentType::Timestamp:
      return (declare ? "{ i64 }" : "timestamp");
    case ExtArgumentType::ColumnListInt8:
      return (declare ? "{i8**, i64, i64}*" : "ColumnList<i8>");
    case ExtArgumentType::ColumnListInt16:
      return (declare ? "{i8**, i64, i64}*" : "ColumnList<i16>");
    case ExtArgumentType::ColumnListInt32:
      return (declare ? "{i8**, i64, i64}*" : "ColumnList<i32>");
    case ExtArgumentType::ColumnListInt64:
      return (declare ? "{i8**, i64, i64}*" : "ColumnList<i64>");
    case ExtArgumentType::ColumnListFloat:
      return (declare ? "{i8**, i64, i64}*" : "ColumnList<float>");
    case ExtArgumentType::ColumnListDouble:
      return (declare ? "{i8**, i64, i64}*" : "ColumnList<double>");
    case ExtArgumentType::ColumnListBool:
      return (declare ? "{i8**, i64, i64}*" : "ColumnList<bool>");
    case ExtArgumentType::ColumnListTextEncodingDict:
      return (declare ? "{i8**, i64, i64}*" : "ColumnList<TextEncodingDict>");
    case ExtArgumentType::ColumnArrayInt8:
      return (declare ? "{i8*, i64}*" : "Column<Array<i8>>");
    case ExtArgumentType::ColumnArrayInt16:
      return (declare ? "{i8*, i64}*" : "Column<Array<i16>>");
    case ExtArgumentType::ColumnArrayInt32:
      return (declare ? "{i8*, i64}*" : "Column<Array<i32>>");
    case ExtArgumentType::ColumnArrayInt64:
      return (declare ? "{i8*, i64}*" : "Column<Array<i64>>");
    case ExtArgumentType::ColumnArrayFloat:
      return (declare ? "{i8*, i64}*" : "Column<Array<float>>");
    case ExtArgumentType::ColumnArrayDouble:
      return (declare ? "{i8*, i64}*" : "Column<Array<double>>");
    case ExtArgumentType::ColumnArrayBool:
      return (declare ? "{i8*, i64}*" : "Column<Array<bool>>");
    case ExtArgumentType::ColumnArrayTextEncodingDict:
      return (declare ? "{i8*, i64}" : "Column<Array<TextEncodingDict>>");
    case ExtArgumentType::ColumnListArrayInt8:
      return (declare ? "{i8**, i64, i64}*" : "ColumnListArray<i8>");
    case ExtArgumentType::ColumnListArrayInt16:
      return (declare ? "{i8**, i64, i64}*" : "ColumnListArray<i16>");
    case ExtArgumentType::ColumnListArrayInt32:
      return (declare ? "{i8**, i64, i64}*" : "ColumnListArray<i32>");
    case ExtArgumentType::ColumnListArrayInt64:
      return (declare ? "{i8**, i64, i64}*" : "ColumnListArray<i64>");
    case ExtArgumentType::ColumnListArrayFloat:
      return (declare ? "{i8**, i64, i64}*" : "ColumnListArray<float>");
    case ExtArgumentType::ColumnListArrayDouble:
      return (declare ? "{i8**, i64, i64}*" : "ColumnListArray<double>");
    case ExtArgumentType::ColumnListArrayBool:
      return (declare ? "{i8**, i64, i64}*" : "ColumnListArray<bool>");
    case ExtArgumentType::ColumnListArrayTextEncodingDict:
      return (declare ? "{i8**, i64, i64}" : "ColumnList<Array<TextEncodingDict>>");
    default:
      CHECK(false);
  }
  CHECK(false);
  return "";
}

std::string drop_suffix(const std::string& str) {
  const auto idx = str.find("__");
  if (idx == std::string::npos) {
    return str;
  }
  CHECK_GT(idx, std::string::size_type(0));
  return str.substr(0, idx);
}

}  // namespace

SQLTypeInfo ext_arg_type_to_type_info(const ExtArgumentType ext_arg_type) {
  SQLTypes type = kNULLT;
  int d = 0;
  int s = 0;
  bool n = false;
  EncodingType c = kENCODING_NONE;
  int p = 0;
  SQLTypes subtype = kNULLT;

#define EXTARGTYPECASE(EXTARGTYPE, ELEMTYPE, ENCODING, ARRAYENCODING) \
  case ExtArgumentType::EXTARGTYPE:                                   \
    type = ELEMTYPE;                                                  \
    c = kENCODING_##ENCODING;                                         \
    break;                                                            \
  case ExtArgumentType::Array##EXTARGTYPE:                            \
    type = kARRAY;                                                    \
    c = kENCODING_##ENCODING;                                         \
    subtype = ELEMTYPE;                                               \
    break;                                                            \
  case ExtArgumentType::Column##EXTARGTYPE:                           \
    type = kCOLUMN;                                                   \
    c = kENCODING_##ENCODING;                                         \
    subtype = ELEMTYPE;                                               \
    break;                                                            \
  case ExtArgumentType::ColumnList##EXTARGTYPE:                       \
    type = kCOLUMN_LIST;                                              \
    c = kENCODING_##ENCODING;                                         \
    subtype = ELEMTYPE;                                               \
    break;                                                            \
  case ExtArgumentType::ColumnArray##EXTARGTYPE:                      \
    type = kCOLUMN;                                                   \
    subtype = ELEMTYPE;                                               \
    c = kENCODING_##ARRAYENCODING;                                    \
    break;                                                            \
  case ExtArgumentType::ColumnListArray##EXTARGTYPE:                  \
    type = kCOLUMN_LIST;                                              \
    subtype = ELEMTYPE;                                               \
    c = kENCODING_##ARRAYENCODING;                                    \
    break;

  switch (ext_arg_type) {
    EXTARGTYPECASE(Bool, kBOOLEAN, NONE, ARRAY);
    EXTARGTYPECASE(Int8, kTINYINT, NONE, ARRAY);
    EXTARGTYPECASE(Int16, kSMALLINT, NONE, ARRAY);
    EXTARGTYPECASE(Int32, kINT, NONE, ARRAY);
    EXTARGTYPECASE(Int64, kBIGINT, NONE, ARRAY);
    EXTARGTYPECASE(Float, kFLOAT, NONE, ARRAY);
    EXTARGTYPECASE(Double, kDOUBLE, NONE, ARRAY);
    EXTARGTYPECASE(TextEncodingNone, kTEXT, NONE, ARRAY);
    EXTARGTYPECASE(TextEncodingDict, kTEXT, DICT, ARRAY_DICT);
    // TODO: EXTARGTYPECASE(Timestamp, kTIMESTAMP, NONE, ARRAY);
    case ExtArgumentType::Timestamp:
      type = kTIMESTAMP;
      c = kENCODING_NONE;
      d = 9;
      break;
    case ExtArgumentType::ColumnTimestamp:
      type = kCOLUMN;
      subtype = kTIMESTAMP;
      c = kENCODING_NONE;
      d = 9;
      break;
    default:
      LOG(FATAL) << "ExtArgumentType `" << serialize_type(ext_arg_type)
                 << "` cannot be converted to SQLTypes.";
      UNREACHABLE();
  }
  return SQLTypeInfo(type, d, s, n, c, p, subtype);
}

std::string ExtensionFunctionsWhitelist::toString(
    const std::vector<ExtensionFunction>& ext_funcs,
    std::string tab) {
  std::string r = "";
  for (auto sig : ext_funcs) {
    r += tab + sig.toString() + "\n";
  }
  return r;
}

std::string ExtensionFunctionsWhitelist::toString(
    const std::vector<SQLTypeInfo>& arg_types) {
  std::string r = "";
  for (auto sig = arg_types.begin(); sig != arg_types.end();) {
    r += sig->get_type_name();
    sig++;
    if (sig != arg_types.end()) {
      r += ", ";
    }
  }
  return r;
}

std::string ExtensionFunctionsWhitelist::toString(
    const std::vector<ExtArgumentType>& sig_types) {
  std::string r = "";
  for (auto t = sig_types.begin(); t != sig_types.end();) {
    r += serialize_type(*t, /* byval */ false, /* declare */ false);
    t++;
    if (t != sig_types.end()) {
      r += ", ";
    }
  }
  return r;
}

std::string ExtensionFunctionsWhitelist::toStringSQL(
    const std::vector<ExtArgumentType>& sig_types) {
  std::string r = "";
  for (auto t = sig_types.begin(); t != sig_types.end();) {
    r += ExtensionFunctionsWhitelist::toStringSQL(*t);
    t++;
    if (t != sig_types.end()) {
      r += ", ";
    }
  }
  return r;
}

std::string ExtensionFunctionsWhitelist::toString(const ExtArgumentType& sig_type) {
  return serialize_type(sig_type, /* byval */ false, /* declare */ false);
}

std::string ExtensionFunctionsWhitelist::toStringSQL(const ExtArgumentType& sig_type) {
  switch (sig_type) {
    case ExtArgumentType::Int8:
      return "TINYINT";
    case ExtArgumentType::Int16:
      return "SMALLINT";
    case ExtArgumentType::Int32:
      return "INTEGER";
    case ExtArgumentType::Int64:
      return "BIGINT";
    case ExtArgumentType::Float:
      return "FLOAT";
    case ExtArgumentType::Double:
      return "DOUBLE";
    case ExtArgumentType::Bool:
      return "BOOLEAN";
    case ExtArgumentType::PInt8:
      return "TINYINT[]";
    case ExtArgumentType::PInt16:
      return "SMALLINT[]";
    case ExtArgumentType::PInt32:
      return "INT[]";
    case ExtArgumentType::PInt64:
      return "BIGINT[]";
    case ExtArgumentType::PFloat:
      return "FLOAT[]";
    case ExtArgumentType::PDouble:
      return "DOUBLE[]";
    case ExtArgumentType::PBool:
      return "BOOLEAN[]";
    case ExtArgumentType::ArrayInt8:
      return "ARRAY<TINYINT>";
    case ExtArgumentType::ArrayInt16:
      return "ARRAY<SMALLINT>";
    case ExtArgumentType::ArrayInt32:
      return "ARRAY<INT>";
    case ExtArgumentType::ArrayInt64:
      return "ARRAY<BIGINT>";
    case ExtArgumentType::ArrayFloat:
      return "ARRAY<FLOAT>";
    case ExtArgumentType::ArrayDouble:
      return "ARRAY<DOUBLE>";
    case ExtArgumentType::ArrayBool:
      return "ARRAY<BOOLEAN>";
    case ExtArgumentType::ArrayTextEncodingDict:
      return "ARRAY<TEXT ENCODING DICT>";
    case ExtArgumentType::ColumnInt8:
      return "COLUMN<TINYINT>";
    case ExtArgumentType::ColumnInt16:
      return "COLUMN<SMALLINT>";
    case ExtArgumentType::ColumnInt32:
      return "COLUMN<INT>";
    case ExtArgumentType::ColumnInt64:
      return "COLUMN<BIGINT>";
    case ExtArgumentType::ColumnFloat:
      return "COLUMN<FLOAT>";
    case ExtArgumentType::ColumnDouble:
      return "COLUMN<DOUBLE>";
    case ExtArgumentType::ColumnBool:
      return "COLUMN<BOOLEAN>";
    case ExtArgumentType::ColumnTextEncodingDict:
      return "COLUMN<TEXT ENCODING DICT>";
    case ExtArgumentType::ColumnTimestamp:
      return "COLUMN<TIMESTAMP(9)>";
    case ExtArgumentType::Cursor:
      return "CURSOR";
    case ExtArgumentType::GeoPoint:
      return "POINT";
    case ExtArgumentType::GeoMultiPoint:
      return "MULTIPOINT";
    case ExtArgumentType::GeoLineString:
      return "LINESTRING";
    case ExtArgumentType::GeoMultiLineString:
      return "MULTILINESTRING";
    case ExtArgumentType::GeoPolygon:
      return "POLYGON";
    case ExtArgumentType::GeoMultiPolygon:
      return "MULTIPOLYGON";
    case ExtArgumentType::Void:
      return "VOID";
    case ExtArgumentType::TextEncodingNone:
      return "TEXT ENCODING NONE";
    case ExtArgumentType::TextEncodingDict:
      return "TEXT ENCODING DICT";
    case ExtArgumentType::Timestamp:
      return "TIMESTAMP(9)";
    case ExtArgumentType::ColumnListInt8:
      return "COLUMNLIST<TINYINT>";
    case ExtArgumentType::ColumnListInt16:
      return "COLUMNLIST<SMALLINT>";
    case ExtArgumentType::ColumnListInt32:
      return "COLUMNLIST<INT>";
    case ExtArgumentType::ColumnListInt64:
      return "COLUMNLIST<BIGINT>";
    case ExtArgumentType::ColumnListFloat:
      return "COLUMNLIST<FLOAT>";
    case ExtArgumentType::ColumnListDouble:
      return "COLUMNLIST<DOUBLE>";
    case ExtArgumentType::ColumnListBool:
      return "COLUMNLIST<BOOLEAN>";
    case ExtArgumentType::ColumnListTextEncodingDict:
      return "COLUMNLIST<TEXT ENCODING DICT>";
    case ExtArgumentType::ColumnArrayInt8:
      return "COLUMN<ARRAY<TINYINT>>";
    case ExtArgumentType::ColumnArrayInt16:
      return "COLUMN<ARRAY<SMALLINT>>";
    case ExtArgumentType::ColumnArrayInt32:
      return "COLUMN<ARRAY<INT>>";
    case ExtArgumentType::ColumnArrayInt64:
      return "COLUMN<ARRAY<BIGINT>>";
    case ExtArgumentType::ColumnArrayFloat:
      return "COLUMN<ARRAY<FLOAT>>";
    case ExtArgumentType::ColumnArrayDouble:
      return "COLUMN<ARRAY<DOUBLE>>";
    case ExtArgumentType::ColumnArrayBool:
      return "COLUMN<ARRAY<BOOLEAN>>";
    case ExtArgumentType::ColumnArrayTextEncodingDict:
      return "COLUMN<ARRAY<TEXT ENCODING DICT>>";
    case ExtArgumentType::ColumnListArrayInt8:
      return "COLUMNLIST<ARRAY<TINYINT>>";
    case ExtArgumentType::ColumnListArrayInt16:
      return "COLUMNLIST<ARRAY<SMALLINT>>";
    case ExtArgumentType::ColumnListArrayInt32:
      return "COLUMNLIST<ARRAY<INT>>";
    case ExtArgumentType::ColumnListArrayInt64:
      return "COLUMNLIST<ARRAY<BIGINT>>";
    case ExtArgumentType::ColumnListArrayFloat:
      return "COLUMNLIST<ARRAY<FLOAT>>";
    case ExtArgumentType::ColumnListArrayDouble:
      return "COLUMNLIST<ARRAY<DOUBLE>>";
    case ExtArgumentType::ColumnListArrayBool:
      return "COLUMNLIST<ARRAY<BOOLEAN>>";
    case ExtArgumentType::ColumnListArrayTextEncodingDict:
      return "COLUMNLIST<ARRAY<TEXT ENCODING DICT>>";
    default:
      UNREACHABLE();
  }
  return "";
}

const std::string ExtensionFunction::getName(bool keep_suffix) const {
  return (keep_suffix ? name_ : drop_suffix(name_));
}

std::string ExtensionFunction::toString() const {
  return getName() + "(" + ExtensionFunctionsWhitelist::toString(args_) + ") -> " +
         ExtensionFunctionsWhitelist::toString({ret_});
}

std::string ExtensionFunction::toStringSQL() const {
  return getName(/* keep_suffix = */ false) + "(" +
         ExtensionFunctionsWhitelist::toStringSQL(args_) + ") -> " +
         ExtensionFunctionsWhitelist::toStringSQL(ret_);
}

std::string ExtensionFunction::toSignature() const {
  return "(" + ExtensionFunctionsWhitelist::toString(args_) + ") -> " +
         ExtensionFunctionsWhitelist::toString(ret_);
}

// Converts the extension function signatures to their LLVM representation.
std::vector<std::string> ExtensionFunctionsWhitelist::getLLVMDeclarations(
    const std::unordered_set<std::string>& udf_decls,
    const bool is_gpu) {
  std::vector<std::string> declarations;
  for (const auto& kv : functions_) {
    const auto& signatures = kv.second;
    CHECK(!signatures.empty());
    for (const auto& signature : kv.second) {
      // If there is a udf function declaration matching an extension function signature
      // do not emit a duplicate declaration.
      if (!udf_decls.empty() && udf_decls.find(signature.getName()) != udf_decls.end()) {
        continue;
      }

      std::string decl_prefix;
      std::vector<std::string> arg_strs;

      if (is_ext_arg_type_array(signature.getRet())) {
        decl_prefix = "declare void @" + signature.getName();
        arg_strs.emplace_back(
            serialize_type(signature.getRet(), /* byval */ true, /* declare */ true));
      } else {
        decl_prefix =
            "declare " +
            serialize_type(signature.getRet(), /* byval */ true, /* declare */ true) +
            " @" + signature.getName();
      }
      for (const auto arg : signature.getInputArgs()) {
        arg_strs.push_back(serialize_type(arg, /* byval */ false, /* declare */ true));
      }
      declarations.push_back(decl_prefix + "(" + boost::algorithm::join(arg_strs, ", ") +
                             ");");
    }
  }

  for (const auto& kv : table_functions::TableFunctionsFactory::functions_) {
    if (kv.second.isRuntime() || kv.second.useDefaultSizer()) {
      // Runtime UDTFs are defined in LLVM/NVVM IR module
      // UDTFs using default sizer share LLVM IR
      continue;
    }
    if (!((is_gpu && kv.second.isGPU()) || (!is_gpu && kv.second.isCPU()))) {
      continue;
    }
    std::string decl_prefix{
        "declare " +
        serialize_type(ExtArgumentType::Int32, /* byval */ true, /* declare */ true) +
        " @" + kv.first};
    std::vector<std::string> arg_strs;
    for (const auto arg : kv.second.getArgs(/* ensure_column = */ true)) {
      arg_strs.push_back(
          serialize_type(arg, /* byval= */ kv.second.isRuntime(), /* declare= */ true));
    }
    declarations.push_back(decl_prefix + "(" + boost::algorithm::join(arg_strs, ", ") +
                           ");");
  }
  return declarations;
}

namespace {

ExtArgumentType deserialize_type(const std::string& type_name) {
  if (type_name == "bool" || type_name == "i1") {
    return ExtArgumentType::Bool;
  }
  if (type_name == "i8") {
    return ExtArgumentType::Int8;
  }
  if (type_name == "i16") {
    return ExtArgumentType::Int16;
  }
  if (type_name == "i32") {
    return ExtArgumentType::Int32;
  }
  if (type_name == "i64") {
    return ExtArgumentType::Int64;
  }
  if (type_name == "float") {
    return ExtArgumentType::Float;
  }
  if (type_name == "double") {
    return ExtArgumentType::Double;
  }
  if (type_name == "void") {
    return ExtArgumentType::Void;
  }
  if (type_name == "i8*") {
    return ExtArgumentType::PInt8;
  }
  if (type_name == "i16*") {
    return ExtArgumentType::PInt16;
  }
  if (type_name == "i32*") {
    return ExtArgumentType::PInt32;
  }
  if (type_name == "i64*") {
    return ExtArgumentType::PInt64;
  }
  if (type_name == "float*") {
    return ExtArgumentType::PFloat;
  }
  if (type_name == "double*") {
    return ExtArgumentType::PDouble;
  }
  if (type_name == "i1*" || type_name == "bool*") {
    return ExtArgumentType::PBool;
  }
  if (type_name == "Array<i8>") {
    return ExtArgumentType::ArrayInt8;
  }
  if (type_name == "Array<i16>") {
    return ExtArgumentType::ArrayInt16;
  }
  if (type_name == "Array<i32>") {
    return ExtArgumentType::ArrayInt32;
  }
  if (type_name == "Array<i64>") {
    return ExtArgumentType::ArrayInt64;
  }
  if (type_name == "Array<float>") {
    return ExtArgumentType::ArrayFloat;
  }
  if (type_name == "Array<double>") {
    return ExtArgumentType::ArrayDouble;
  }
  if (type_name == "Array<bool>" || type_name == "Array<i1>") {
    return ExtArgumentType::ArrayBool;
  }
  if (type_name == "Array<TextEncodingDict>") {
    return ExtArgumentType::ArrayTextEncodingDict;
  }
  if (type_name == "geo_point") {
    return ExtArgumentType::GeoPoint;
  }
  if (type_name == "geo_multi_point") {
    return ExtArgumentType::GeoMultiPoint;
  }
  if (type_name == "geo_linestring") {
    return ExtArgumentType::GeoLineString;
  }
  if (type_name == "geo_multi_linestring") {
    return ExtArgumentType::GeoMultiLineString;
  }
  if (type_name == "geo_polygon") {
    return ExtArgumentType::GeoPolygon;
  }
  if (type_name == "geo_multi_polygon") {
    return ExtArgumentType::GeoMultiPolygon;
  }
  if (type_name == "cursor") {
    return ExtArgumentType::Cursor;
  }
  if (type_name == "Column<i8>") {
    return ExtArgumentType::ColumnInt8;
  }
  if (type_name == "Column<i16>") {
    return ExtArgumentType::ColumnInt16;
  }
  if (type_name == "Column<i32>") {
    return ExtArgumentType::ColumnInt32;
  }
  if (type_name == "Column<i64>") {
    return ExtArgumentType::ColumnInt64;
  }
  if (type_name == "Column<float>") {
    return ExtArgumentType::ColumnFloat;
  }
  if (type_name == "Column<double>") {
    return ExtArgumentType::ColumnDouble;
  }
  if (type_name == "Column<bool>") {
    return ExtArgumentType::ColumnBool;
  }
  if (type_name == "Column<TextEncodingDict>") {
    return ExtArgumentType::ColumnTextEncodingDict;
  }
  if (type_name == "Column<timestamp>") {
    return ExtArgumentType::ColumnTimestamp;
  }
  if (type_name == "TextEncodingNone") {
    return ExtArgumentType::TextEncodingNone;
  }
  if (type_name == "TextEncodingDict") {
    return ExtArgumentType::TextEncodingDict;
  }
  if (type_name == "timestamp") {
    return ExtArgumentType::Timestamp;
  }
  if (type_name == "ColumnList<i8>") {
    return ExtArgumentType::ColumnListInt8;
  }
  if (type_name == "ColumnList<i16>") {
    return ExtArgumentType::ColumnListInt16;
  }
  if (type_name == "ColumnList<i32>") {
    return ExtArgumentType::ColumnListInt32;
  }
  if (type_name == "ColumnList<i64>") {
    return ExtArgumentType::ColumnListInt64;
  }
  if (type_name == "ColumnList<float>") {
    return ExtArgumentType::ColumnListFloat;
  }
  if (type_name == "ColumnList<double>") {
    return ExtArgumentType::ColumnListDouble;
  }
  if (type_name == "ColumnList<bool>") {
    return ExtArgumentType::ColumnListBool;
  }
  if (type_name == "ColumnList<TextEncodingDict>") {
    return ExtArgumentType::ColumnListTextEncodingDict;
  }
  if (type_name == "Column<Array<i8>>") {
    return ExtArgumentType::ColumnArrayInt8;
  }
  if (type_name == "Column<Array<i16>>") {
    return ExtArgumentType::ColumnArrayInt16;
  }
  if (type_name == "Column<Array<i32>>") {
    return ExtArgumentType::ColumnArrayInt32;
  }
  if (type_name == "Column<Array<i64>>") {
    return ExtArgumentType::ColumnArrayInt64;
  }
  if (type_name == "Column<Array<float>>") {
    return ExtArgumentType::ColumnArrayFloat;
  }
  if (type_name == "Column<Array<double>>") {
    return ExtArgumentType::ColumnArrayDouble;
  }
  if (type_name == "Column<Array<bool>>") {
    return ExtArgumentType::ColumnArrayBool;
  }
  if (type_name == "Column<Array<TextEncodingDict>>") {
    return ExtArgumentType::ColumnArrayTextEncodingDict;
  }
  if (type_name == "ColumnList<Array<i8>>") {
    return ExtArgumentType::ColumnListArrayInt8;
  }
  if (type_name == "ColumnList<Array<i16>>") {
    return ExtArgumentType::ColumnListArrayInt16;
  }
  if (type_name == "ColumnList<Array<i32>>") {
    return ExtArgumentType::ColumnListArrayInt32;
  }
  if (type_name == "ColumnList<Array<i64>>") {
    return ExtArgumentType::ColumnListArrayInt64;
  }
  if (type_name == "ColumnList<Array<float>>") {
    return ExtArgumentType::ColumnListArrayFloat;
  }
  if (type_name == "ColumnList<Array<double>>") {
    return ExtArgumentType::ColumnListArrayDouble;
  }
  if (type_name == "ColumnList<Array<bool>>") {
    return ExtArgumentType::ColumnListArrayBool;
  }
  if (type_name == "ColumnList<Array<TextEncodingDict>>") {
    return ExtArgumentType::ColumnListArrayTextEncodingDict;
  }
  CHECK(false);
  return ExtArgumentType::Int16;
}

}  // namespace

using SignatureMap = std::unordered_map<std::string, std::vector<ExtensionFunction>>;

void ExtensionFunctionsWhitelist::addCommon(SignatureMap& signatures,
                                            const std::string& json_func_sigs,
                                            const bool is_runtime) {
  rapidjson::Document func_sigs;
  func_sigs.Parse(json_func_sigs.c_str());
  CHECK(func_sigs.IsArray());
  for (auto func_sigs_it = func_sigs.Begin(); func_sigs_it != func_sigs.End();
       ++func_sigs_it) {
    CHECK(func_sigs_it->IsObject());
    const auto name = json_str(field(*func_sigs_it, "name"));
    const auto ret = deserialize_type(json_str(field(*func_sigs_it, "ret")));
    std::vector<ExtArgumentType> args;
    const auto& args_serialized = field(*func_sigs_it, "args");
    CHECK(args_serialized.IsArray());
    for (auto args_serialized_it = args_serialized.Begin();
         args_serialized_it != args_serialized.End();
         ++args_serialized_it) {
      args.push_back(deserialize_type(json_str(*args_serialized_it)));
    }
    signatures[to_upper(drop_suffix(name))].emplace_back(name, args, ret, is_runtime);
  }
}

// Calcite loads the available extensions from `ExtensionFunctions.ast`, adds
// them to its operator table and shares the list with the execution layer in
// JSON format. Build an in-memory representation of that list here so that it
// can be used by getLLVMDeclarations(), when the LLVM IR codegen asks for it.
void ExtensionFunctionsWhitelist::add(const std::string& json_func_sigs) {
  // Valid json_func_sigs example:
  // [
  //    {
  //       "name":"sum",
  //       "ret":"i32",
  //       "args":[
  //          "i32",
  //          "i32"
  //       ]
  //    }
  // ]

  addCommon(functions_, json_func_sigs, /* is_runtime */ false);
}

void ExtensionFunctionsWhitelist::addUdfs(const std::string& json_func_sigs) {
  if (!json_func_sigs.empty()) {
    addCommon(udf_functions_, json_func_sigs, /* is_runtime */ false);
  }
}

void ExtensionFunctionsWhitelist::clearRTUdfs() {
  rt_udf_functions_.clear();
}

void ExtensionFunctionsWhitelist::addRTUdfs(const std::string& json_func_sigs) {
  if (!json_func_sigs.empty()) {
    addCommon(rt_udf_functions_, json_func_sigs, /* is_runtime */ true);
  }
}

std::unordered_map<std::string, std::vector<ExtensionFunction>>
    ExtensionFunctionsWhitelist::functions_;

std::unordered_map<std::string, std::vector<ExtensionFunction>>
    ExtensionFunctionsWhitelist::udf_functions_;

std::unordered_map<std::string, std::vector<ExtensionFunction>>
    ExtensionFunctionsWhitelist::rt_udf_functions_;

std::string toString(const ExtArgumentType& sig_type) {
  return ExtensionFunctionsWhitelist::toString(sig_type);
}