diff options
| author | AlexSm <[email protected]> | 2024-01-04 15:09:05 +0100 |
|---|---|---|
| committer | GitHub <[email protected]> | 2024-01-04 15:09:05 +0100 |
| commit | dab291146f6cd7d35684e3a1150e5bb1c412982c (patch) | |
| tree | 36ef35f6cacb6432845a4a33f940c95871036b32 /contrib/clickhouse/src/Functions/h3GetOriginIndexFromUnidirectionalEdge.cpp | |
| parent | 63660ad5e7512029fd0218e7a636580695a24e1f (diff) | |
Library import 5, delete go dependencies (#832)
* Library import 5, delete go dependencies
* Fix yt client
Diffstat (limited to 'contrib/clickhouse/src/Functions/h3GetOriginIndexFromUnidirectionalEdge.cpp')
| -rw-r--r-- | contrib/clickhouse/src/Functions/h3GetOriginIndexFromUnidirectionalEdge.cpp | 95 |
1 files changed, 0 insertions, 95 deletions
diff --git a/contrib/clickhouse/src/Functions/h3GetOriginIndexFromUnidirectionalEdge.cpp b/contrib/clickhouse/src/Functions/h3GetOriginIndexFromUnidirectionalEdge.cpp deleted file mode 100644 index 21b389b2bb1..00000000000 --- a/contrib/clickhouse/src/Functions/h3GetOriginIndexFromUnidirectionalEdge.cpp +++ /dev/null @@ -1,95 +0,0 @@ -#include "clickhouse_config.h" - -#if USE_H3 - -#include <Columns/ColumnArray.h> -#include <Columns/ColumnsNumber.h> -#include <DataTypes/DataTypeArray.h> -#include <DataTypes/DataTypesNumber.h> -#include <Functions/FunctionFactory.h> -#include <Functions/IFunction.h> -#include <Common/typeid_cast.h> -#include <IO/WriteHelpers.h> -#include <base/range.h> -#include <constants.h> -#include <h3api.h> - - -namespace DB -{ -namespace ErrorCodes -{ - extern const int ILLEGAL_TYPE_OF_ARGUMENT; - extern const int ILLEGAL_COLUMN; -} - -namespace -{ - -class FunctionH3GetOriginIndexFromUnidirectionalEdge : public IFunction -{ -public: - static constexpr auto name = "h3GetOriginIndexFromUnidirectionalEdge"; - - static FunctionPtr create(ContextPtr) { return std::make_shared<FunctionH3GetOriginIndexFromUnidirectionalEdge>(); } - - std::string getName() const override { return name; } - - size_t getNumberOfArguments() const override { return 1; } - bool useDefaultImplementationForConstants() const override { return true; } - bool isSuitableForShortCircuitArgumentsExecution(const DataTypesWithConstInfo & /*arguments*/) const override { return true; } - - DataTypePtr getReturnTypeImpl(const DataTypes & arguments) const override - { - const auto * arg = arguments[0].get(); - if (!WhichDataType(arg).isUInt64()) - throw Exception( - ErrorCodes::ILLEGAL_TYPE_OF_ARGUMENT, - "Illegal type {} of argument {} of function {}. Must be UInt64", - arg->getName(), 1, getName()); - - return std::make_shared<DataTypeUInt64>(); - } - - ColumnPtr executeImpl(const ColumnsWithTypeAndName & arguments, const DataTypePtr &, size_t input_rows_count) const override - { - auto non_const_arguments = arguments; - for (auto & argument : non_const_arguments) - argument.column = argument.column->convertToFullColumnIfConst(); - - const auto * col_hindex_edge = checkAndGetColumn<ColumnUInt64>(non_const_arguments[0].column.get()); - if (!col_hindex_edge) - throw Exception( - ErrorCodes::ILLEGAL_COLUMN, - "Illegal type {} of argument {} of function {}. Must be UInt64.", - arguments[0].type->getName(), - 1, - getName()); - - const auto & data_hindex_edge = col_hindex_edge->getData(); - - auto dst = ColumnVector<UInt64>::create(); - auto & dst_data = dst->getData(); - dst_data.resize(input_rows_count); - - for (size_t row = 0; row < input_rows_count; ++row) - { - const UInt64 edge = data_hindex_edge[row]; - const UInt64 res = getDirectedEdgeOrigin(edge); - dst_data[row] = res; - } - - return dst; - } -}; - -} - -REGISTER_FUNCTION(H3GetOriginIndexFromUnidirectionalEdge) -{ - factory.registerFunction<FunctionH3GetOriginIndexFromUnidirectionalEdge>(); -} - -} - -#endif |
