o
    EDiw                     @   sP   d dl mZ ddlmZmZ ddlmZmZ G dd deZG dd	 d	eZ	d
S )    )block   )BaseCompressorBaseDecompressor   )CompressionMethodCompressionMethodBytec                   @   s$   e Zd ZejZejZdZdd Z	dS )
Compressordefaultc                 C   s   t j|d| jdS )NF)
store_sizemode)r   compressr   )selfdata r   Z/var/www/Datamplify/venv/lib/python3.10/site-packages/clickhouse_driver/compression/lz4.pycompress_data   s   zCompressor.compress_dataN)
__name__
__module____qualname__r   LZ4methodr   method_byter   r   r   r   r   r   r	      s
    r	   c                   @   s    e Zd ZejZejZdd ZdS )Decompressorc                 C   s   t j||dS )N)uncompressed_size)r   
decompress)r   r   r   r   r   r   decompress_data   s   zDecompressor.decompress_dataN)	r   r   r   r   r   r   r   r   r   r   r   r   r   r      s    r   N)
lz4r   baser   r   protocolr   r   r	   r   r   r   r   r   <module>   s
    	