+ =i-XRt^RIHt^RIt^RItRt]tRt^tRt ]PPt ]PPt!RR]4tRtRR ltRR lt]t!R R 4t!R R4t!RR4t!RR4t]]3Rlt]]R3Rlt]3Rlt]3RltRtRtR#)zpython-snappy Python library for the snappy compression library from Google. Expected usage like: import snappy compressed = snappy.compress("some data") assert "some data" == snappy.uncompress(compressed) )absolute_importNissNaPpYs sNaPpYc]tRt^:tRtR#)UncompressErrorN)__name__ __module__ __qualname____firstlineno____static_attributes__rp/Users/tonyclaw/.openclaw/workspace/scripts/youtube-playlists/venv/lib/python3.14/site-packages/snappy/snappy.pyrr:sr rc\V\4'dVPR4pRp\V4V# \dpRpRp?T#Rp?ii;i)utf-8TFN) isinstancestrencode decompressr)dataokerrs& r isValidCompressedr>sR${{7# B4 I   Is 8 AA  Acx\V\4'dVPV4p\\ V44#N)rrrbytes _compress)rencodings&&r compressrJs,${{8$ 4 !!r c\V\4'd \R4h\\ V44pT'dTPT4#T# \ P d p\ThRp?ii;i)z&It's only possible to uncompress bytesN)rrrr _uncompresscramjamDecompressionErrordecode)rdecodingoutrs&& r uncompressr$Psh$FGG'K%&zz(## J  % %'3&'sAA3'A..A3cPa]tRt^^toRtRtR V3RlRllt]tRtRt Rt Vt R#) StreamCompressoraiThis class implements the compressor-side of the proposed Snappy framing format, found at http://code.google.com/p/snappy/source/browse/trunk/framing_format.txt ?spec=svn68&r=71 This class matches the interface found for the zlib module's compression objects (see zlib.compressobj), but also provides some additions, such as the snappy framing format's ability to intersperse uncompressed data. Keep in mind that this compressor object does no buffering for you to appropriately size chunks. Every call to StreamCompressor.compress results in a unique call to the underlying snappy compression method. cL\PP4VnR#r)rsnappy Compressorcselfs&r __init__StreamCompressor.__init__os**,r Nc <V^8dQhRS[/#rr)format __classdict__s"r __annotate__StreamCompressor.__annotate__rser c XVPPV4VP4#)Add a chunk, returning a string that is framed and compressed. Outputs a single snappy chunk; if it is the very start of the stream, will also contain the stream header chunk. )r*rflush)r,rrs&&&r add_chunkStreamCompressor.add_chunkrs zz|r cH\VPP44#rrr*r9r+s&r r9StreamCompressor.flush}TVV\\^$$r c V#zHThis method exists for compatibility with the zlib compressobj. rr+s&r copyStreamCompressor.copy  r )r*r) rrrr __doc__r-r:rr9rBr __classdictcell__r4s@r r&r&^s/ -H%r r&cXa]tRt^toRtRt]R4tV3RlRltRt Rt Rt Vt R #) StreamDecompressoraThis class implements the decompressor-side of the proposed Snappy framing format, found at http://code.google.com/p/snappy/source/browse/trunk/framing_format.txt ?spec=svn68&r=71 This class matches a subset of the interface found for the zlib module's decompression objects (see zlib.decompressobj). Specifically, it currently implements the decompress method without the max_length option, the flush method without the length option, and the copy method. cZ\PP4VnRVnR#r)rr( Decompressorr*remainsr+s&r r-StreamDecompressor.__init__s,,. r c ^VP\\44\8H# R#;i)z{Does this stream start with a stream header block? True indicates that the stream can likely be decoded using this class. F)readlen_STREAM_HEADER_BLOCK)fins&r check_formatStreamDecompressor.check_formats,  88C 456:NN N s$',c <V^8dQhRS[/#r0r2)r3r4s"r r5StreamDecompressor.__annotate__sur c VP'dVPV,pRVnVP\4'g\V,p\V4p\\4pV^,V8d WnR#\P W^,V^,R4^,pW28XdM&WC,V8dWRVnVRVpM W4, pK[VP PV4VP4#):Decompress 'data', returning a string containing the uncompressed data corresponding to at least part of the data in string. This data should be concatenated to the output produced by any preceding calls to the decompress() method. Some of the input data may be preserved in internal buffers for later processing. Nr little) rL startswithrQrPint from_bytesr*rr9)r,rldatabsize this_sizes&& r rStreamDecompressor.decompresss <<<<<$&DDL344'$.DD () 19u LtAIuqy'A8LqPI~ 5(#F| FU|  E $zz|r cH\VPP44#rr=r+s&r r9StreamDecompressor.flushr?r cV#rrr+s&r rBStreamDecompressor.copy r )r*rLN) rrrr rEr- staticmethodrSrr9rBr rFrGs@r rIrIs= @%r rIcFa]tRt^toRV3RlRllt]tRtRtRtVt R#)HadoopStreamCompressorNc <V^8dQhRS[/#r0r2)r3r4s"r r5#HadoopStreamCompressor.__annotate__s^^e^r c \V4pRP\V4P^R4\V4P^R4V34#)r8r big)rjoinrPto_bytes)r,rrcdatas&&& r r: HadoopStreamCompressor.add_chunksF $xxT++Au5s5z7J7J1e7TV[\]]r cR#r rr+s&r r9HadoopStreamCompressor.flushsr c V#rArr+s&r rBHadoopStreamCompressor.copyrDr rr) rrrr r:rr9rBr rFrGs@r rhrhs'^^Hr rhcTa]tRt^toRt]R4tV3RlRltRtRt Rt Vt R#) HadoopStreamDecompressorcRVnR#)r NrLr+s&r r-!HadoopStreamDecompressor.__init__s  r c ^RIHpVP^^4pVP^4V^8gQh\P VP ^4R4pW28gQhVP ^4V!V4# R#;i)z4Does this look like a hadoop snappy stream? )check_unframed_formatrlF)snappy.snappy_formatsr|seekr[r\rO)rRr|size chunk_lengths& r rS%HadoopStreamDecompressor.check_formatst  C88Aq>D HHQK19 9>>#((1+u=L& && HHQK(- - s A7A::A?c <V^8dQhRS[/#r0r2)r3r4s"r r5%HadoopStreamDecompressor.__annotate__sur c VP'dVPV,pRVn\V4^8d WnR#.p\PVR,R4p\V4^V,8dWnM2VP \ V^^V,44V^V,RpKnRP V4#)rXNr :Nrl)rLrPr[r\appendrrm)r,rr#rs&& r r#HadoopStreamDecompressor.decompresss <<<<<$&DDL t9q=L>>$s)U;L4y1|++#  JJ{4!l*:#;< =L()*Dxx}r cR#rrrr+s&r r9HadoopStreamDecompressor.flush sr cV#rrr+s&r rBHadoopStreamDecompressor.copyrer ryN) rrrr r-rfrSrr9rBr rFrGs@r rwrws7 .r rwcV!4pVPV4pV'gR#VPV4pV'gK7VPV4KJ)a Takes an incoming file-like object and an outgoing file-like object, reads data from src, compresses it, and writes it to dst. 'src' should support the read method, and 'dst' should support the write method. The default blocksize is good for almost every scenario. N)rOr:write)srcdst blocksizecompressor_cls compressorbufs&&&& r stream_compressrsA !J hhy!E""3' 3 #r cV!4pV'dTpRpMVPV4pV'gM.VPV4pV'gKCVPV4KVVP4R#)aTakes an incoming file-like object and an outgoing file-like object, reads data from src, decompresses it, and writes it to dst. 'src' should support the read method, and 'dst' should support the write method. The default blocksize is good for almost every scenario. :param decompressor_cls: class that implements `decompress` method like StreamDecompressor in the module :param start_chunk: start block of data that have already been read from the input stream (to detect the format, for example) N)rOrrr9)rrrdecompressor_cls start_chunk decompressorrs&&&&& r stream_decompressr%sZ$%L  CK((9%C%%c* 3 #r c\4pVPV4pV'gM.VPV4pV'gK6VPV4KIVP 4R#TN)rwrOrrr9rrrr*rrs&&& r hadoop_stream_decompressrAsJ !"A xx " ll4  3 IIcNIIKr c\4pVPV4pV'gM.VPV4pV'gK6VPV4KIVP 4R#r)rhrOrrr9rs&&& r hadoop_stream_compressrQsJ  A xx " jj 3 IIcNIIKr cZVP4pVP\V44R#r)rOrrrrrs&& r raw_stream_decompressras 88:DIIjr cZVP4pVP\V44R#r)rOrrrs&& r raw_stream_compressrfs 88:DIIhtnr )rr)rE __future__rstructr _CHUNK_MAX_STREAM_TO_STREAM_BLOCK_SIZE_STREAM_IDENTIFIER_IDENTIFIER_CHUNKrQr( compress_rawrdecompress_rawr Exceptionrrrr$rr&rIrhrwrrrrrrrr r rs> '   )0 NN ' ' nn++  i  "  %%P@@F,00l;#3(!='9"& >+ &+   r