2018-03-29 14:04:24 +00:00
|
|
|
#pragma once
|
2018-03-14 10:47:13 +00:00
|
|
|
#include <Columns/IColumn.h>
|
|
|
|
|
|
|
|
namespace DB
|
|
|
|
{
|
|
|
|
|
2018-03-19 11:45:17 +00:00
|
|
|
class IColumnUnique : public IColumn
|
2018-03-14 10:47:13 +00:00
|
|
|
{
|
|
|
|
public:
|
|
|
|
/// Column always contains Null if it's Nullable and empty string if it's String or Nullable(String).
|
|
|
|
/// So, size may be greater than the number of inserted unique values.
|
2018-03-29 14:04:24 +00:00
|
|
|
virtual const ColumnPtr & getNestedColumn() const = 0;
|
2018-03-19 11:45:17 +00:00
|
|
|
size_t size() const override { return getNestedColumn()->size(); }
|
2018-03-14 10:47:13 +00:00
|
|
|
|
|
|
|
/// Appends new value at the end of column (column's size is increased by 1).
|
|
|
|
/// Is used to transform raw strings to Blocks (for example, inside input format parsers)
|
2018-03-19 11:45:17 +00:00
|
|
|
virtual size_t uniqueInsert(const Field & x) = 0;
|
2018-03-14 10:47:13 +00:00
|
|
|
|
2018-03-19 11:45:17 +00:00
|
|
|
virtual size_t uniqueInsertFrom(const IColumn & src, size_t n) = 0;
|
2018-03-14 10:47:13 +00:00
|
|
|
/// Appends range of elements from other column.
|
|
|
|
/// Could be used to concatenate columns.
|
2018-03-19 11:45:17 +00:00
|
|
|
virtual ColumnPtr uniqueInsertRangeFrom(const IColumn & src, size_t start, size_t length) = 0;
|
2018-03-14 10:47:13 +00:00
|
|
|
|
|
|
|
/// Appends data located in specified memory chunk if it is possible (throws an exception if it cannot be implemented).
|
|
|
|
/// Is used to optimize some computations (in aggregation, for example).
|
|
|
|
/// Parameter length could be ignored if column values have fixed size.
|
2018-03-19 11:45:17 +00:00
|
|
|
virtual size_t uniqueInsertData(const char * pos, size_t length) = 0;
|
|
|
|
virtual size_t uniqueInsertDataWithTerminatingZero(const char * pos, size_t length) = 0;
|
2018-03-14 10:47:13 +00:00
|
|
|
|
2018-03-19 11:45:17 +00:00
|
|
|
virtual size_t getDefaultValueIndex() const = 0;
|
|
|
|
virtual size_t getNullValueIndex() const = 0;
|
|
|
|
virtual bool canContainNulls() const = 0;
|
2018-03-14 10:47:13 +00:00
|
|
|
|
2018-03-19 11:45:17 +00:00
|
|
|
virtual size_t uniqueDeserializeAndInsertFromArena(const char * pos, const char *& new_pos) = 0;
|
|
|
|
|
|
|
|
// virtual size_t getInsertionPoint(const char * pos, size_t length) const = 0;
|
|
|
|
//
|
|
|
|
// virtual bool has(const char * pos, size_t length) const { return getInsertionPoint(pos, length) != size(); }
|
|
|
|
|
|
|
|
const char * getFamilyName() const override { return "ColumnUnique"; }
|
|
|
|
|
2018-03-29 14:04:24 +00:00
|
|
|
void insert(const Field &) override
|
2018-03-19 11:45:17 +00:00
|
|
|
{
|
|
|
|
throw Exception("Method insert is not supported for ColumnUnique.", ErrorCodes::NOT_IMPLEMENTED);
|
|
|
|
}
|
|
|
|
|
2018-03-29 14:04:24 +00:00
|
|
|
void insertRangeFrom(const IColumn &, size_t, size_t) override
|
2018-03-19 11:45:17 +00:00
|
|
|
{
|
|
|
|
throw Exception("Method insertRangeFrom is not supported for ColumnUnique.", ErrorCodes::NOT_IMPLEMENTED);
|
|
|
|
}
|
|
|
|
|
2018-03-29 14:04:24 +00:00
|
|
|
void insertData(const char *, size_t) override
|
2018-03-19 11:45:17 +00:00
|
|
|
{
|
|
|
|
throw Exception("Method insertData is not supported for ColumnUnique.", ErrorCodes::NOT_IMPLEMENTED);
|
|
|
|
}
|
|
|
|
|
|
|
|
void insertDefault() override
|
|
|
|
{
|
|
|
|
throw Exception("Method insertDefault is not supported for ColumnUnique.", ErrorCodes::NOT_IMPLEMENTED);
|
|
|
|
}
|
|
|
|
|
2018-03-29 14:04:24 +00:00
|
|
|
void popBack(size_t) override
|
2018-03-19 11:45:17 +00:00
|
|
|
{
|
|
|
|
throw Exception("Method popBack is not supported for ColumnUnique.", ErrorCodes::NOT_IMPLEMENTED);
|
|
|
|
}
|
|
|
|
|
2018-03-29 14:04:24 +00:00
|
|
|
void gather(ColumnGathererStream &) override
|
2018-03-19 11:45:17 +00:00
|
|
|
{
|
|
|
|
throw Exception("Method gather is not supported for ColumnUnique.", ErrorCodes::NOT_IMPLEMENTED);
|
|
|
|
}
|
2018-03-29 14:04:24 +00:00
|
|
|
|
|
|
|
const char * deserializeAndInsertFromArena(const char *) override
|
|
|
|
{
|
|
|
|
throw Exception("Method deserializeAndInsertFromArena is not supported for ColumnUnique.", ErrorCodes::NOT_IMPLEMENTED);
|
|
|
|
}
|
2018-04-23 16:40:25 +00:00
|
|
|
|
2018-04-23 16:51:27 +00:00
|
|
|
ColumnPtr index(const ColumnPtr &, size_t) const override
|
2018-04-23 16:40:25 +00:00
|
|
|
{
|
|
|
|
throw Exception("Method index is not supported for ColumnUnique.", ErrorCodes::NOT_IMPLEMENTED);
|
|
|
|
}
|
2018-06-06 11:20:27 +00:00
|
|
|
|
|
|
|
ColumnPtr cut(size_t, size_t) const override
|
|
|
|
{
|
|
|
|
throw Exception("Method cut is not supported for ColumnUnique.", ErrorCodes::NOT_IMPLEMENTED);
|
|
|
|
}
|
|
|
|
|
|
|
|
ColumnPtr filter(const IColumn::Filter &, ssize_t) const override
|
|
|
|
{
|
|
|
|
throw Exception("Method filter is not supported for ColumnUnique.", ErrorCodes::NOT_IMPLEMENTED);
|
|
|
|
}
|
|
|
|
|
|
|
|
ColumnPtr permute(const IColumn::Permutation &, size_t) const override
|
|
|
|
{
|
|
|
|
throw Exception("Method permute is not supported for ColumnUnique.", ErrorCodes::NOT_IMPLEMENTED);
|
|
|
|
}
|
|
|
|
|
|
|
|
ColumnPtr replicate(const IColumn::Offsets &) const override
|
|
|
|
{
|
|
|
|
throw Exception("Method replicate is not supported for ColumnUnique.", ErrorCodes::NOT_IMPLEMENTED);
|
|
|
|
}
|
|
|
|
|
|
|
|
void getPermutation(bool, size_t, int, IColumn::Permutation &) const override
|
|
|
|
{
|
|
|
|
throw Exception("Method getPermutation is not supported for ColumnUnique.", ErrorCodes::NOT_IMPLEMENTED);
|
|
|
|
}
|
|
|
|
|
|
|
|
std::vector<MutableColumnPtr> scatter(IColumn::ColumnIndex, const IColumn::Selector &) const override
|
|
|
|
{
|
|
|
|
throw Exception("Method scatter is not supported for ColumnUnique.", ErrorCodes::NOT_IMPLEMENTED);
|
|
|
|
}
|
2018-03-14 10:47:13 +00:00
|
|
|
};
|
|
|
|
|
|
|
|
}
|