Базовые модули

Особенности реализации:

• Основные компоненты, самый нижний уровень всего кода.

• Являются основой проекта.

• Могут быть установлены отдельно.

• Не имеют зависимостей, либо минимально зависят от сторонних библиотек.

• light_compressor
  • GitHub
  • PyPI
  • Установка модуля light-compressor без установки dbhose-airflow
    • LZ4Compressor
      • LZ4Compressor
      • decompressed_size
      • send_chunks()
    • LZ4Decompressor
      • LZ4Decompressor
      • eof
      • needs_input
      • unused_data
      • decompress()
      • reset()
    • ZSTDCompressor
      • ZSTDCompressor
      • compression_level
      • decompressed_size
      • send_chunks()
    • ZSTDDecompressor
      • ZSTDDecompressor
      • eof
      • needs_input
      • unused_data
      • decompress()
      • reset()
    • CompressionMethod
      • CompressionMethod
      • NONE
      • LZ4
      • ZSTD
      • method
    • auto_detector
      • auto_detector()
    • define_reader
      • define_reader()
    • define_writer
      • define_writer()
• nativelib
  • GitHub
  • PyPI
  • Установка модуля nativelib без установки dbhose-airflow
    • NativeReader
      • NativeReader
      • total_blocks
      • total_rows
      • read_info()
      • to_rows()
      • to_pandas()
      • to_polars()
      • tell()
      • close()
    • NativeWriter
      • NativeWriter
      • total_blocks
      • total_rows
      • from_rows()
      • from_pandas()
      • from_polars()
    • common
      • length
        • Импорт модуля (внутренние функции, написано только как пример)
        • read_length
          • read_length()
        • write_length
          • write_length()
      • pandas_astype
        • pandas_astype()
        • Импорт модуля (внутренняя функция, написано только как пример)
      • blocks
        • BlockReader
          • BlockReader
          • total_columns
          • total_rows
          • column_list
          • columns
          • read_column()
          • skip()
          • read()
        • BlockWriter
          • BlockWriter
          • max_block_size
          • total_columns
          • total_rows
          • block_size
          • headers_size
          • data_iterator
          • write_row()
          • clear_block()
          • init_dataset()
          • write()
      • columns
        • ColumnInfo
          • ColumnInfo
          • column
          • dtype
          • is_array
          • is_lowcardinality
          • is_nullable
          • length
          • precision
          • scale
          • tzinfo
          • enumcase
          • nested
          • make_dtype()
        • Column
          • Column
          • info
          • dtype
          • data
          • iter_data
          • total_rows
          • skip()
          • read()
          • write()
          • tell()
          • clear()
      • dtypes
        • booleans
          • read_bool
          • write_bool
          • read_nothing
          • write_nothing
        • dates
          • read_date
          • write_date
          • read_date32
          • write_date32
          • read_datetime
          • write_datetime
          • read_datetime64
          • write_datetime64
          • read_time
          • write_time
          • read_time64
          • write_time64
        • decimals
          • read_decimal
          • write_decimal
        • enums
          • read_enum
          • write_enum
        • floats
          • read_bfloat16
          • write_bfloat16
          • read_float
          • write_float
        • integers
          • read_int
          • write_int
          • read_uint
          • write_uint
          • r_uint
            • r_uint()
          • w_uint
            • w_uint()
        • ipaddrs
          • read_ipv4
          • write_ipv4
          • read_ipv6
          • write_ipv6
        • strings
          • read_string
          • write_string
        • uuids
          • read_uuid
          • write_uuid
        • from_dtype
        • ClickhouseDtype
          • ClickhouseDtype
          • DTypeFunc
        • Array
          • Array
          • row_elements
          • writable_buffer
          • skip()
          • read()
          • write()
          • tell()
          • clear()
        • DType
          • nullable_map
          • nullable_buffer
          • writable_buffer
          • read_dtype()
          • write_dtype()
          • skip()
          • read()
          • write()
          • tell()
          • clear()
        • LowCardinality
          • dictionary
          • index_elements
          • index_size
          • skip()
          • read()
          • write()
          • tell()
          • clear()
      • DEFAULT_BLOCK_SIZE
        • DEFAULT_BLOCK_SIZE
• pgcopylib
  • GitHub
  • PyPI
  • Установка модуля pgcopylib без установки dbhose-airflow
    • PGCopyReader
      • PGCopyReader
      • num_columns
      • num_rows
      • postgres_dtype
      • is_oid_enable
      • read_row()
      • to_rows()
      • tell()
      • close()
    • PGCopyWriter
      • PGCopyWriter
      • num_columns
      • num_rows
      • pos
      • postgres_dtype
      • write_row()
      • from_rows()
      • write()
      • tell()
      • close()
    • common
      • dtypes
        • arrays
          • read_array
            • read_array()
          • write_array
            • write_array()
        • dates
          • read_date
            • read_date()
          • write_date
            • write_date()
          • read_timestamp
            • read_timestamp()
          • write_timestamp
            • write_timestamp()
          • read_timestamptz
            • read_timestamptz()
          • write_timestamptz
            • write_timestamptz()
          • read_time
            • read_time()
          • write_time
            • write_time()
          • read_timetz
            • read_timetz()
          • write_timetz
            • write_timetz()
          • read_interval
            • read_interval()
          • write_interval
            • write_interval()
        • digits
          • read_bool
            • read_bool()
          • write_bool
            • write_bool()
          • read_oid
            • read_oid()
          • write_oid
            • write_oid()
          • read_int2
            • read_int2()
          • write_int2
            • write_int2()
          • read_int4
            • read_int4()
          • write_int4
            • write_int4()
          • read_int8
            • read_int8()
          • write_int8
            • write_int8()
          • read_money
            • read_money()
          • write_money
            • write_money()
          • read_float4
            • read_float4()
          • write_float4
            • write_float4()
          • read_float8
            • read_float8()
          • write_float8
            • write_float8()
          • read_numeric
            • read_numeric()
          • write_numeric
            • write_numeric()
        • geometrics
          • read_point
            • read_point()
          • write_point
            • write_point()
          • read_line
            • read_line()
          • write_line
            • write_line()
          • read_lseg
            • read_lseg()
          • write_lseg
            • write_lseg()
          • read_box
            • read_box()
          • write_box
            • write_box()
          • read_path
            • read_path()
          • write_path
            • write_path()
          • read_polygon
            • read_polygon()
          • write_polygon
            • write_polygon()
        • ipaddrs
          • read_network
            • read_network()
          • write_network
            • write_network()
        • jsons
          • read_json
            • read_json()
          • write_json
            • write_json()
        • strings
          • read_text
            • read_text()
          • write_text
            • write_text()
          • read_macaddr
            • read_macaddr()
          • write_macaddr
            • write_macaddr()
          • read_bits
            • read_bits()
          • write_bits
            • write_bits()
          • read_bytea
            • read_bytea()
          • write_bytea
            • write_bytea()
        • uuids
          • read_uuid
            • read_uuid()
          • write_uuid
            • write_uuid()
        • PostgreSQLDtype
          • PostgreSQLDtype
          • PGTypeFunc
      • base
        • read_num_columns
          • read_num_columns()
        • read_record
          • read_record()
        • skip_all
          • skip_all()
        • writer
          • writer()
        • nullable_writer
          • nullable_writer()
        • make_rows
          • make_rows()
      • enums
        • PGOid
          • PGOid
        • ArrayOidToOid
          • ArrayOidToOid
        • PGOidToDType
          • PGOidToDType
      • errors
        • PGCopySignatureError
          • PGCopySignatureError
        • PGCopyRecordError
          • PGCopyRecordError
      • BufferObject
        • BufferObject
        • read()
• pgpack
  • GitHub
  • PyPI
  • Установка модуля pgpack без установки dbhose-airflow
    • PGPackReader
      • PGPackReader
      • metadata
      • columns
      • pgtypes
      • pgparam
      • compression_method
      • pgcopy_data_length
      • pgcopy_compressed_length
      • to_rows()
      • to_pandas()
      • to_polars()
      • to_bytes()
      • tell()
      • close()
    • PGPackWriter
      • metadata
      • columns
      • pgtypes
      • compression_method
      • pgcopy_data_length
      • pgcopy_compressed_length
      • from_rows()
      • from_pandas()
      • from_polars()
      • from_bytes()
      • tell()
      • close()
    • common
      • detect_oid
        • detect_oid()
      • pandas_astype
        • pandas_astype()
      • errors
        • PGPackError
          • PGPackError
        • PGPackHeaderError
          • PGPackHeaderError
        • PGPackMetadataCrcError
          • PGPackMetadataCrcError
        • PGPackModeError
          • PGPackModeError
      • metadata
        • metadata_reader
          • metadata_reader()
        • metadata_from_frame
          • metadata_from_frame()
      • PGParam
        • PGParam
      • HEADER
        • HEADER