#include #include #include #include #include #include #include namespace DB { /// Implements the function isNotNull which returns true if a value /// is not null, false otherwise. class FunctionIsNotNull : public IFunction { public: static constexpr auto name = "isNotNull"; static FunctionPtr create(const Context &) { return std::make_shared(); } std::string getName() const override { return name; } size_t getNumberOfArguments() const override { return 1; } bool useDefaultImplementationForNulls() const override { return false; } bool useDefaultImplementationForConstants() const override { return true; } ColumnNumbers getArgumentsThatDontImplyNullableReturnType(size_t /*number_of_arguments*/) const override { return {0}; } DataTypePtr getReturnTypeImpl(const DataTypes &) const override { return std::make_shared(); } void executeImpl(Block & block, const ColumnNumbers & arguments, size_t result, size_t input_rows_count) override { const ColumnWithTypeAndName & elem = block.getByPosition(arguments[0]); if (auto * nullable = checkAndGetColumn(*elem.column)) { /// Return the negated null map. auto res_column = ColumnUInt8::create(input_rows_count); const auto & src_data = nullable->getNullMapData(); auto & res_data = assert_cast(*res_column).getData(); for (size_t i = 0; i < input_rows_count; ++i) res_data[i] = !src_data[i]; block.getByPosition(result).column = std::move(res_column); } else { /// Since no element is nullable, return a constant one. block.getByPosition(result).column = DataTypeUInt8().createColumnConst(elem.column->size(), 1u); } } }; void registerFunctionIsNotNull(FunctionFactory & factory) { factory.registerFunction(); } }