ClickHouse/dbms/include/DB/Columns/ColumnAggregateFunction.h

77 lines
1.6 KiB
C
Raw Normal View History

2011-09-19 01:42:16 +00:00
#pragma once
#include <DB/AggregateFunctions/IAggregateFunction.h>
#include <DB/Columns/ColumnVector.h>
namespace DB
{
/** Столбец, хранящий состояния агрегатных функций.
*/
class ColumnAggregateFunction : public ColumnVector<AggregateFunctionPtr>
2011-09-19 01:42:16 +00:00
{
public:
std::string getName() const { return "ColumnAggregateFunction"; }
2012-05-30 03:30:29 +00:00
ColumnPtr cloneEmpty() const { return new ColumnAggregateFunction; };
2011-09-19 01:42:16 +00:00
bool isNumeric() const { return false; }
Field operator[](size_t n) const
{
return data[n];
}
void get(size_t n, Field & res) const
{
res = data[n];
}
StringRef getDataAt(size_t n) const
{
throw Exception("Method getDataAt is not supported for " + getName(), ErrorCodes::NOT_IMPLEMENTED);
}
2011-09-19 01:42:16 +00:00
void cut(size_t start, size_t length)
{
if (start + length > data.size())
2011-09-19 01:42:16 +00:00
throw Exception("Parameters start = "
+ Poco::NumberFormatter::format(start) + ", length = "
+ Poco::NumberFormatter::format(length) + " are out of bound in IColumnVector<T>::cut() method"
" (data.size() = " + Poco::NumberFormatter::format(data.size()) + ").",
ErrorCodes::PARAMETER_OUT_OF_BOUND);
if (start == 0)
data.resize(length);
else
{
Container_t tmp(data.begin() + start, data.begin() + start + length);
tmp.swap(data);
}
}
void insert(const Field & x)
{
data.push_back(DB::get<const AggregateFunctionPtr &>(x));
2011-09-19 01:42:16 +00:00
}
int compareAt(size_t n, size_t m, const IColumn & rhs_) const
{
return 0;
}
2011-09-26 11:05:38 +00:00
Permutation getPermutation() const
2011-09-26 11:05:38 +00:00
{
size_t s = data.size();
Permutation res(s);
2011-09-26 11:05:38 +00:00
for (size_t i = 0; i < s; ++i)
res[i] = i;
return res;
2011-09-26 11:05:38 +00:00
}
2011-09-19 01:42:16 +00:00
};
}