// Licensed to the Apache Software Foundation (ASF) under one // or more contributor license agreements. See the NOTICE file // distributed with this work for additional information // regarding copyright ownership. The ASF licenses this file // to you 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 "vec/columns/column_complex.h" #include "vec/data_types/data_type.h" #include "vec/data_types/data_type_bitmap.h" #include "vec/functions/function_const.h" #include "vec/functions/function_string.h" #include "vec/functions/function_totype.h" #include "vec/functions/simple_function_factory.h" namespace doris::vectorized { #define BITMAP_FUNCTION_VARIADIC(CLASS, FUNCTION_NAME, OP) \ struct CLASS { \ static constexpr auto name = #FUNCTION_NAME; \ using ResultDataType = DataTypeBitMap; \ static Status vector_vector(ColumnPtr argument_columns[], size_t col_size, \ size_t input_rows_count, std::vector& res) { \ auto& mid_data = \ assert_cast(argument_columns[0].get())->get_data(); \ for (size_t row = 0; row < input_rows_count; ++row) { \ res[row] = mid_data[row]; \ } \ for (size_t col = 1; col < col_size; ++col) { \ auto& col_data = \ assert_cast(argument_columns[col].get())->get_data(); \ for (size_t row = 0; row < input_rows_count; ++row) { \ res[row] OP col_data[row]; \ } \ } \ return Status::OK(); \ } \ } #define BITMAP_FUNCTION_COUNT_VARIADIC(CLASS, FUNCTION_NAME, OP) \ struct CLASS { \ static constexpr auto name = #FUNCTION_NAME; \ using ResultDataType = DataTypeInt64; \ using TData = std::vector; \ using ResTData = typename ColumnVector::Container; \ static Status vector_vector(ColumnPtr argument_columns[], size_t col_size, \ size_t input_rows_count, ResTData& res) { \ TData vals = assert_cast(argument_columns[0].get())->get_data(); \ for (size_t col = 1; col < col_size; ++col) { \ auto& col_data = \ assert_cast(argument_columns[col].get())->get_data(); \ for (size_t row = 0; row < input_rows_count; ++row) { \ vals[row] OP col_data[row]; \ } \ } \ for (size_t row = 0; row < input_rows_count; ++row) { \ res[row] = vals[row].cardinality(); \ } \ return Status::OK(); \ } \ } BITMAP_FUNCTION_VARIADIC(BitmapOr, bitmap_or, |=); BITMAP_FUNCTION_VARIADIC(BitmapAnd, bitmap_and, &=); BITMAP_FUNCTION_VARIADIC(BitmapXor, bitmap_xor, ^=); BITMAP_FUNCTION_COUNT_VARIADIC(BitmapOrCount, bitmap_or_count, |=); BITMAP_FUNCTION_COUNT_VARIADIC(BitmapAndCount, bitmap_and_count, &=); BITMAP_FUNCTION_COUNT_VARIADIC(BitmapXorCount, bitmap_xor_count, ^=); template class FunctionBitMapVariadic : public IFunction { public: static constexpr auto name = Impl::name; static FunctionPtr create() { return std::make_shared(); } String get_name() const override { return name; } size_t get_number_of_arguments() const override { return 0; } bool is_variadic() const override { return true; } DataTypePtr get_return_type_impl(const DataTypes& arguments) const override { using ResultDataType = typename Impl::ResultDataType; return std::make_shared(); } bool use_default_implementation_for_constants() const override { return true; } Status execute_impl(FunctionContext* context, Block& block, const ColumnNumbers& arguments, size_t result, size_t input_rows_count) override { size_t argument_size = arguments.size(); ColumnPtr argument_columns[argument_size]; for (size_t i = 0; i < argument_size; ++i) { argument_columns[i] = block.get_by_position(arguments[i]).column->convert_to_full_column_if_const(); } using ResultDataType = typename Impl::ResultDataType; //DataTypeBitMap or DataTypeInt64 using ResultType = typename ResultDataType::FieldType; //BitmapValue or Int64 using ColVecResult = std::conditional_t, ColumnComplexType, ColumnVector>; typename ColVecResult::MutablePtr col_res = nullptr; col_res = ColVecResult::create(); auto& vec_res = col_res->get_data(); vec_res.resize(input_rows_count); Impl::vector_vector(argument_columns, argument_size, input_rows_count, vec_res); block.replace_by_position(result, std::move(col_res)); return Status::OK(); } }; using FunctionBitmapOr = FunctionBitMapVariadic; using FunctionBitmapXor = FunctionBitMapVariadic; using FunctionBitmapAnd = FunctionBitMapVariadic; using FunctionBitmapOrCount = FunctionBitMapVariadic; using FunctionBitmapAndCount = FunctionBitMapVariadic; using FunctionBitmapXorCount = FunctionBitMapVariadic; void register_function_bitmap_variadic(SimpleFunctionFactory& factory) { factory.register_function(); factory.register_function(); factory.register_function(); factory.register_function(); factory.register_function(); factory.register_function(); } } // namespace doris::vectorized