#pragma once #include #include #include #include #include namespace DB { using Poco::SharedPtr; class IColumn; typedef SharedPtr ColumnPtr; typedef std::vector Columns; typedef std::vector ColumnPlainPtrs; typedef std::vector ConstColumnPlainPtrs; /** Интерфейс для хранения столбцов значений в оперативке. */ class IColumn : private boost::noncopyable { public: /** Имя столбца. Для информационных сообщений. */ virtual std::string getName() const = 0; /** Столбец представляет собой вектор чисел или числовую константу. */ virtual bool isNumeric() const { return false; } /** Столбец представляет собой константу. */ virtual bool isConst() const { return false; } /** Значения имеют фиксированную длину. */ virtual bool isFixed() const { return false; } /** Для столбцов фиксированной длины - вернуть длину значения. */ virtual size_t sizeOfField() const { throw Exception("Cannot get sizeOfField() for column " + getName(), ErrorCodes::CANNOT_GET_SIZE_OF_FIELD); } /** Создать пустой столбец такого же типа */ virtual SharedPtr cloneEmpty() const { return cloneResized(0); } /** Создать столбец такого же типа и указанного размера. * Если размер меньше текущего, данные обрезаются. * Если больше - добавляются значения по умолчанию. */ virtual SharedPtr cloneResized(size_t size) const { throw Exception("Cannot cloneResized() column " + getName(), ErrorCodes::NOT_IMPLEMENTED); } /** Количество значений в столбце. */ virtual size_t size() const = 0; bool empty() const { return size() == 0; } /** Получить значение n-го элемента. * Используется для преобразования из блоков в строки (например, при выводе значений в текстовый дамп) */ virtual Field operator[](size_t n) const = 0; /** То же самое, но позволяет избежать лишнего копирования, если Field, например, кладётся в контейнер. */ virtual void get(size_t n, Field & res) const = 0; /** Получить кусок памяти, в котором хранится значение, если возможно. * (если не реализуемо - кидает исключение) * Используется для оптимизации некоторых вычислений (например, агрегации). */ virtual StringRef getDataAt(size_t n) const = 0; /** Отличется от функции getDataAt только для строк переменной длины. * Для них возвращаются данные с нулём на конце (то есть, size на единицу больше длины строки). */ virtual StringRef getDataAtWithTerminatingZero(size_t n) const { return getDataAt(n); } /** Удалить всё кроме диапазона элементов. * Используется, например, для операции LIMIT. */ virtual SharedPtr cut(size_t start, size_t length) const = 0; /** Вставить значение в конец столбца (количество значений увеличится на 1). * Используется для преобразования из строк в блоки (например, при чтении значений из текстового дампа) */ virtual void insert(const Field & x) = 0; /** Вставить значение в конец столбца из другого столбца такого же типа, по заданному индексу. * Используется для merge-sort. Может быть реализована оптимальнее, чем реализация по-умолчанию. */ virtual void insertFrom(const IColumn & src, size_t n) { insert(src[n]); } /** Вставить данные, расположенные в указанном куске памяти, если возможно. * (если не реализуемо - кидает исключение) * Используется для оптимизации некоторых вычислений (например, агрегации). * В случае данных постоянной длины, параметр length может игнорироваться. */ virtual void insertData(const char * pos, size_t length) = 0; /** Отличется от функции insertData только для строк переменной длины. * Для них принимаются данные уже с нулём на конце (то есть, length на единицу больше длины строки). * В переданном куске памяти обязательно должен быть ноль на конце. */ virtual void insertDataWithTerminatingZero(const char * pos, size_t length) { insertData(pos, length); } /** Вставить значение "по умолчанию". * Используется, когда нужно увеличить размер столбца, но значение не имеет смысла. * Например, для ColumnNullable, если взведён флаг null, то соответствующее значение во вложенном столбце игнорируется. */ virtual void insertDefault() = 0; /** Соединить столбец с одним или несколькими другими. * Используется при склейке маленьких блоков. */ //virtual void merge(const Columns & columns) = 0; /** Оставить только значения, соответствующие фильтру. * Используется для операции WHERE / HAVING. */ typedef std::vector Filter; virtual SharedPtr filter(const Filter & filt) const = 0; /** Переставить значения местами, используя указанную перестановку. * Используется при сортировке. */ typedef std::vector Permutation; virtual SharedPtr permute(const Permutation & perm) const = 0; /** Сравнить (*this)[n] и rhs[m]. * Вернуть отрицательное число, 0, или положительное число, если меньше, равно, или больше, соответственно. * Используется при сортировке. */ virtual int compareAt(size_t n, size_t m, const IColumn & rhs) const = 0; /** Получить перестановку чисел, такую, что их порядок соответствует порядку значений в столбце. * Используется при сортировке. */ virtual Permutation getPermutation() const = 0; /** Размножить все значения столько раз, сколько прописано в offsets. * (i-е значение размножается в offsets[i] - offsets[i - 1] значений.) */ typedef UInt64 Offset_t; typedef std::vector Offsets_t; virtual SharedPtr replicate(const Offsets_t & offsets) const = 0; /** Если возможно - зарезервировать место для указанного количества элементов. Если невозможно или не поддерживается - ничего не делать. * Функция влияет только на производительность. */ virtual void reserve(size_t n) {}; /** Приблизительный размер столбца в оперативке в байтах - для профайлинга. 0 - если неизвестно. */ virtual size_t byteSize() const = 0; virtual ~IColumn() {} }; }