2012-08-23 18:45:59 +00:00
|
|
|
#pragma once
|
|
|
|
|
2017-04-01 09:19:00 +00:00
|
|
|
#include <Core/Block.h>
|
2012-08-23 18:45:59 +00:00
|
|
|
|
|
|
|
|
|
|
|
namespace DB
|
|
|
|
{
|
|
|
|
|
2016-07-10 02:14:23 +00:00
|
|
|
/** Column, that is just group of few another columns.
|
|
|
|
*
|
2017-12-07 05:53:23 +00:00
|
|
|
* For constant Tuples, see ColumnConst.
|
2016-07-10 02:14:23 +00:00
|
|
|
* Mixed constant/non-constant columns is prohibited in tuple
|
|
|
|
* for implementation simplicity.
|
2012-08-23 18:45:59 +00:00
|
|
|
*/
|
2017-12-14 03:56:56 +00:00
|
|
|
class ColumnTuple final : public COWPtrHelper<IColumn, ColumnTuple>
|
2012-08-23 18:45:59 +00:00
|
|
|
{
|
|
|
|
private:
|
2017-12-14 04:25:22 +00:00
|
|
|
friend class COWPtrHelper<IColumn, ColumnTuple>;
|
|
|
|
|
2017-04-01 07:20:54 +00:00
|
|
|
Columns columns;
|
2012-08-23 18:45:59 +00:00
|
|
|
|
2017-04-01 07:20:54 +00:00
|
|
|
template <bool positive>
|
|
|
|
struct Less;
|
2017-03-12 12:56:59 +00:00
|
|
|
|
2017-12-08 00:50:25 +00:00
|
|
|
ColumnTuple(const Columns & columns);
|
2017-12-14 03:56:56 +00:00
|
|
|
ColumnTuple(const ColumnTuple &) = default;
|
2014-10-31 22:15:17 +00:00
|
|
|
|
2017-12-14 03:56:56 +00:00
|
|
|
public:
|
2017-12-07 05:53:23 +00:00
|
|
|
std::string getName() const override;
|
2017-12-07 22:11:51 +00:00
|
|
|
const char * getFamilyName() const override { return "Tuple"; }
|
2014-10-31 22:15:17 +00:00
|
|
|
|
2017-12-14 03:56:56 +00:00
|
|
|
MutableColumnPtr cloneEmpty() const override;
|
2012-08-23 18:45:59 +00:00
|
|
|
|
2017-04-01 07:20:54 +00:00
|
|
|
size_t size() const override
|
|
|
|
{
|
2017-12-08 00:50:25 +00:00
|
|
|
return columns.at(0)->size();
|
2017-04-01 07:20:54 +00:00
|
|
|
}
|
2012-08-23 18:45:59 +00:00
|
|
|
|
2017-04-01 07:20:54 +00:00
|
|
|
Field operator[](size_t n) const override;
|
|
|
|
void get(size_t n, Field & res) const override;
|
2017-03-12 12:56:59 +00:00
|
|
|
|
2017-04-01 07:20:54 +00:00
|
|
|
StringRef getDataAt(size_t n) const override;
|
|
|
|
void insertData(const char * pos, size_t length) override;
|
|
|
|
void insert(const Field & x) override;
|
|
|
|
void insertFrom(const IColumn & src_, size_t n) override;
|
|
|
|
void insertDefault() override;
|
|
|
|
void popBack(size_t n) override;
|
|
|
|
StringRef serializeValueIntoArena(size_t n, Arena & arena, char const *& begin) const override;
|
|
|
|
const char * deserializeAndInsertFromArena(const char * pos) override;
|
|
|
|
void updateHashWithValue(size_t n, SipHash & hash) const override;
|
|
|
|
void insertRangeFrom(const IColumn & src, size_t start, size_t length) override;
|
2017-12-14 03:56:56 +00:00
|
|
|
MutableColumnPtr filter(const Filter & filt, ssize_t result_size_hint) const override;
|
|
|
|
MutableColumnPtr permute(const Permutation & perm, size_t limit) const override;
|
2017-12-15 21:32:25 +00:00
|
|
|
MutableColumnPtr replicate(const Offsets & offsets) const override;
|
2017-12-15 01:34:30 +00:00
|
|
|
MutableColumns scatter(ColumnIndex num_columns, const Selector & selector) const override;
|
2017-07-06 13:54:55 +00:00
|
|
|
void gather(ColumnGathererStream & gatherer_stream) override;
|
2017-04-01 07:20:54 +00:00
|
|
|
int compareAt(size_t n, size_t m, const IColumn & rhs, int nan_direction_hint) const override;
|
|
|
|
void getExtremes(Field & min, Field & max) const override;
|
|
|
|
void getPermutation(bool reverse, size_t limit, int nan_direction_hint, Permutation & res) const override;
|
|
|
|
void reserve(size_t n) override;
|
|
|
|
size_t byteSize() const override;
|
2017-07-13 16:49:09 +00:00
|
|
|
size_t allocatedBytes() const override;
|
2017-12-07 12:09:55 +00:00
|
|
|
void forEachSubcolumn(ColumnCallback callback) override;
|
2012-08-23 18:45:59 +00:00
|
|
|
|
2017-12-15 19:46:24 +00:00
|
|
|
size_t tupleSize() const { return columns.size(); }
|
|
|
|
|
2017-04-01 07:20:54 +00:00
|
|
|
const Columns & getColumns() const { return columns; }
|
2017-12-15 02:36:40 +00:00
|
|
|
|
|
|
|
const ColumnPtr & getColumnPtr(size_t idx) const { return columns[idx]; }
|
|
|
|
MutableColumnPtr getColumnPtr(size_t idx) { return columns[idx]->assumeMutable(); }
|
2012-08-23 18:45:59 +00:00
|
|
|
};
|
|
|
|
|
|
|
|
|
|
|
|
}
|