#include #include #include #include namespace DB { namespace ErrorCodes { extern const int FUNCTION_IS_SPECIAL; extern const int ILLEGAL_TYPE_OF_ARGUMENT; } /** arrayJoin(arr) - a special function - it can not be executed directly; * is used only to get the result type of the corresponding expression. */ class FunctionArrayJoin : public IFunction { public: static constexpr auto name = "arrayJoin"; static FunctionPtr create(ContextPtr) { return std::make_shared(); } /// Get the function name. String getName() const override { return name; } size_t getNumberOfArguments() const override { return 1; } /** It could return many different values for single argument. */ bool isDeterministic() const override { return false; } bool isDeterministicInScopeOfQuery() const override { return false; } DataTypePtr getReturnTypeImpl(const DataTypes & arguments) const override { const DataTypeArray * arr = checkAndGetDataType(arguments[0].get()); if (!arr) throw Exception("Argument for function " + getName() + " must be Array.", ErrorCodes::ILLEGAL_TYPE_OF_ARGUMENT); return arr->getNestedType(); } ColumnPtr executeImpl(const ColumnsWithTypeAndName &, const DataTypePtr &, size_t /*input_rows_count*/) const override { throw Exception("Function " + getName() + " must not be executed directly.", ErrorCodes::FUNCTION_IS_SPECIAL); } /// Because of function cannot be executed directly. bool isSuitableForConstantFolding() const override { return false; } }; void registerFunctionArrayJoin(FunctionFactory & factory) { factory.registerFunction(); } }