Fixed error with aggregate function anyHeavy [#METR-21691].

This commit is contained in:
Alexey Milovidov 2016-07-17 20:06:19 +03:00
parent 55ed2904f4
commit e66ba2e1d8

View File

@ -582,6 +582,7 @@ struct AggregateFunctionAnyHeavyData : Data
if (counter == 0)
{
this->change(column, row_num);
++counter;
return true;
}
else
@ -609,6 +610,18 @@ struct AggregateFunctionAnyHeavyData : Data
return false;
}
void write(WriteBuffer & buf, const IDataType & data_type) const
{
Data::write(buf, data_type);
writeBinary(counter, buf);
}
void read(ReadBuffer & buf, const IDataType & data_type)
{
Data::read(buf, data_type);
readBinary(counter, buf);
}
static const char * name() { return "anyHeavy"; }
};