thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-19 22:22:00 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix build failure

Browse Source
This commit is contained in:
Bharat Nallan Chakravarthy 2022-12-14 23:49:51 -08:00
parent eb3ea68c3b
commit aa03712b6d
2 changed files with 29 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/AggregateFunctions/AggregateFunctionQuantileInterpolatedWeighted.cpp
View File

@ -53,7 +53,6 @@ namespace
throw Exception("Illegal type " + argument_type->getName() + " of argument for aggregate function " + name, throw Exception("Illegal type " + argument_type->getName() + " of argument for aggregate function " + name,
ErrorCodes::ILLEGAL_TYPE_OF_ARGUMENT); ErrorCodes::ILLEGAL_TYPE_OF_ARGUMENT);
} }
} }
void registerAggregateFunctionsQuantileInterpolatedWeighted(AggregateFunctionFactory & factory) void registerAggregateFunctionsQuantileInterpolatedWeighted(AggregateFunctionFactory & factory)

46
src/AggregateFunctions/QuantileInterpolatedWeighted.h
View File

@ -75,8 +75,31 @@ struct QuantileInterpolatedWeighted
} }
} }
/// Get the value of the `level` quantile. The level must be between 0 and 1.
Value get(Float64 level) const Value get(Float64 level) const
{
return getImpl<Value>(level);
}
void getMany(const Float64 * levels, const size_t * indices, size_t size, Value * result) const
{
getManyImpl<Value>(levels, indices, size, result);
}
/// The same, but in the case of an empty state, NaN is returned.
Float64 getFloat(Float64) const
{
throw Exception("Method getFloat is not implemented for QuantileInterpolatedWeighted", ErrorCodes::NOT_IMPLEMENTED);
}
void getManyFloat(const Float64 *, const size_t *, size_t, Float64 *) const
{
throw Exception("Method getManyFloat is not implemented for QuantileInterpolatedWeighted", ErrorCodes::NOT_IMPLEMENTED);
}
private:
/// Get the value of the `level` quantile. The level must be between 0 and 1.
template <typename T>
T getImpl(Float64 level) const
{ {
size_t size = map.size(); size_t size = map.size();
@ -164,13 +187,13 @@ struct QuantileInterpolatedWeighted
if (level > xr) if (level > xr)
yl = yr; yl = yr;
return interpolate(level, xl, xr, yl, yr); return static_cast<T>(interpolate(level, xl, xr, yl, yr));
} }
/// Get the `size` values of `levels` quantiles. Write `size` results starting with `result` address. /// Get the `size` values of `levels` quantiles. Write `size` results starting with `result` address.
/// indices - an array of index levels such that the corresponding elements will go in ascending order. /// indices - an array of index levels such that the corresponding elements will go in ascending order.
void getMany(const Float64 * levels, const size_t * indices, size_t num_levels, Value * result) const template <typename T>
void getManyImpl(const Float64 * levels, const size_t * indices, size_t num_levels, Value * result) const
{ {
size_t size = map.size(); size_t size = map.size();
@ -258,7 +281,7 @@ struct QuantileInterpolatedWeighted
if (level > xr) if (level > xr)
yl = yr; yl = yr;
result[indices[level_index]] = interpolate(level, xl, xr, yl, yr); result[indices[level_index]] = static_cast<T>(interpolate(level, xl, xr, yl, yr));
++level_index; ++level_index;
} }
} }
@ -272,21 +295,10 @@ struct QuantileInterpolatedWeighted
dx = dx == 0 ? 1 : dx; /// to handle NaN behavior that might arise during integer division below. dx = dx == 0 ? 1 : dx; /// to handle NaN behavior that might arise during integer division below.
/// yl + (dy / dx) * (level - xl) /// yl + (dy / dx) * (level - xl)
UnderlyingType g = common::addIgnoreOverflow(yl, common::mulIgnoreOverflow((dy / dx), common::subIgnoreOverflow(level, xl))); UnderlyingType g = static_cast<UnderlyingType>(common::addIgnoreOverflow(yl, common::mulIgnoreOverflow((dy / dx), common::subIgnoreOverflow(level, xl))));
return g; return g;
} }
/// The same, but in the case of an empty state, NaN is returned.
Float64 getFloat(Float64) const
{
throw Exception("Method getFloat is not implemented for QuantileInterpolatedWeighted", ErrorCodes::NOT_IMPLEMENTED);
}
void getManyFloat(const Float64 *, const size_t *, size_t, Float64 *) const
{
throw Exception("Method getManyFloat is not implemented for QuantileInterpolatedWeighted", ErrorCodes::NOT_IMPLEMENTED);
}
}; };
} }