thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-12-02 20:42:04 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fxi checks

Browse Source
This commit is contained in:
kssenii 2021-06-01 08:45:04 +00:00
parent 32095a2b74
commit 7453d0ce58
3 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/AggregateFunctions/IAggregateFunction.h
View File

@ -105,7 +105,7 @@ public:
virtual void merge(AggregateDataPtr __restrict place, ConstAggregateDataPtr rhs, Arena * arena) const = 0; virtual void merge(AggregateDataPtr __restrict place, ConstAggregateDataPtr rhs, Arena * arena) const = 0;
/// Serializes state (to transmit it over the network, for example). /// Serializes state (to transmit it over the network, for example).
virtual void serialize(ConstAggregateDataPtr __restrict place, WriteBuffer & buf, std::optional<size_t> verison = std::nullopt) const = 0; virtual void serialize(ConstAggregateDataPtr __restrict place, WriteBuffer & buf, std::optional<size_t> version = std::nullopt) const = 0;
/// Deserializes state. This function is called only for empty (just created) states. /// Deserializes state. This function is called only for empty (just created) states.
virtual void deserialize(AggregateDataPtr __restrict place, ReadBuffer & buf, std::optional<size_t> version = std::nullopt, Arena * arena = nullptr) const = 0; virtual void deserialize(AggregateDataPtr __restrict place, ReadBuffer & buf, std::optional<size_t> version = std::nullopt, Arena * arena = nullptr) const = 0;

2
src/DataTypes/DataTypeAggregateFunction.cpp
View File

@ -151,7 +151,7 @@ static DataTypePtr create(const ASTPtr & arguments)
* it is parametric, or [ASTIdentifier, types...] - otherwise. If aggregate function has version in AST, then it will be: * it is parametric, or [ASTIdentifier, types...] - otherwise. If aggregate function has version in AST, then it will be:
* [ASTLitearl, ASTFunction (or ASTIdentifier), types...]. * [ASTLitearl, ASTFunction (or ASTIdentifier), types...].
*/ */
if (auto version_ast = arguments->children[0]->as<ASTLiteral>()) if (auto * version_ast = arguments->children[0]->as<ASTLiteral>())
{ {
version = version_ast->value.safeGet<UInt64>(); version = version_ast->value.safeGet<UInt64>();
data_type_ast = arguments->children[1]; data_type_ast = arguments->children[1];

2
src/Interpreters/InterpreterCreateQuery.cpp
View File

@ -395,7 +395,7 @@ ColumnsDescription InterpreterCreateQuery::getColumnsDescription(
{ {
column_type = DataTypeFactory::instance().get(col_decl.type); column_type = DataTypeFactory::instance().get(col_decl.type);
auto aggregate_function_type = typeid_cast<const DataTypeAggregateFunction *>(column_type.get()); const auto * aggregate_function_type = typeid_cast<const DataTypeAggregateFunction *>(column_type.get());
if (attach && aggregate_function_type && aggregate_function_type->isVersioned()) if (attach && aggregate_function_type && aggregate_function_type->isVersioned())
aggregate_function_type->setVersionIfEmpty(0); aggregate_function_type->setVersionIfEmpty(0);