BlockReader

class BlockReader(fileobj)
Параметры:

fileobj (BufferedReader) – Файловый объект для чтения

Чтение блоков данных из Native формата ClickHouse.

Описание:

Обрабатывает блоки данных Native формата, состоящие из заголовка (количество колонок, количество строк) и данных колонок. Поддерживает чтение построчно и пакетную обработку.

Атрибуты:

total_columns: int

Количество колонок в блоке.

total_rows: int

Количество строк в блоке.

column_list: list[Column]

Список объектов колонок.

columns: list[str]

Список имен колонок.

Методы:

read_column()

Чтение одной колонки из блока.

skip()
Результат:

Размер пропущенного блока

Тип результата:

int

Пропуск всего блока данных.

read()
Результат:

Генератор кортежей значений строк

Тип результата:

Generator[tuple[Any], None, None]

Построчное чтение блока данных.

Использование:

В NativeReader для декомпозиции Native формата на отдельные блоки.