+ nDjƒ%ãóÚ€^RIt^RIt^RIHtHtHtHtHtH t H t H t H t H t HtHtHtHtHtHtHt^RIHt!RR]P,4tRt]R,R,t!RR ]P44t!R R ]P84t!R R ]P<4tRt Rt!RR/Rlt"R] R2]"n#RRRR/Rlt$RRRR/Rlt%R] R2]%n#R!RRRR/Rllt&RRRR/Rlt'RR/R lt(R#)"éN)ÚIpcReadOptionsÚIpcWriteOptionsÚ ReadStatsÚ WriteStatsÚMessageÚ MessageReaderÚRecordBatchReaderÚ_ReadPandasMixinÚMetadataVersionÚ AlignmentÚ read_messageÚread_record_batchÚ read_schemaÚ read_tensorÚ write_tensorÚget_record_batch_sizeÚget_tensor_sizecó6a€]tRt^"toRtRRRR/RltRtVtR#)ÚRecordBatchStreamReaderaÓ Reader for the Arrow streaming binary format. Parameters ---------- source : bytes/buffer-like, pyarrow.NativeFile, or file-like Python object Either an in-memory buffer, or a readable file object. If you want to use memory map use MemoryMappedFile as source. options : pyarrow.ipc.IpcReadOptions Options for IPC deserialization. If None, default values will be used. memory_pool : MemoryPool, default None If None, default memory pool is used. ÚoptionsNÚ memory_poolcóB€\V4pVPWVR7R#)©rrN©Ú _ensure_default_ipc_read_optionsÚ_open)ÚselfÚsourcerrs&&$$ÚE/data/cameron/venvs/s3viz/lib/python3.14/site-packages/pyarrow/ipc.pyÚ__init__Ú RecordBatchStreamReader.__init__2s€Ü2°7Ó;ˆØ ‰ 6¸ ˆ ÖDó©©Ú__name__Ú __module__Ú __qualname__Ú__firstlineno__Ú__doc__r Ú__static_attributes__Ú__classdictcell__©Ú __classdict__s@rrr"s&ø‡€ñ ðE¨$ðE¸D÷EòEr"raOParameters ---------- sink : str, pyarrow.NativeFile, or file-like Python object Either a file path, or a writable file object. schema : pyarrow.Schema The Arrow schema for data to be written to the file. options : pyarrow.ipc.IpcWriteOptions Options for IPC serialization. If None, default values will be used: the legacy format will not be used unless overridden by setting the environment variable ARROW_PRE_0_15_IPC_FORMAT=1, and the V5 metadata version will be used unless overridden by setting the environment variable ARROW_PRE_1_0_METADATA_VERSION=1.Ú zÎmetadata : dict | pyarrow.KeyValueMetadata, optional Key/value pairs (both must be bytes-like) that will be stored in the file footer and are retrievable via pyarrow.ipc.open_file(...).metadata.có8a€]tRt^StoR] 2tRR/RltRtVtR#)ÚRecordBatchStreamWriterz.Writer for the Arrow streaming binary format rNcóB€\V4pVPWVR7R#)©rN©Ú_get_legacy_format_defaultr)rÚsinkÚschemars&&&$rr Ú RecordBatchStreamWriter.__init__Xs€Ü,¨WÓ5ˆØ ‰ 4¨ˆ Ö1r"r#) r%r&r'r(Ú_ipc_writer_class_docr)r r*r+r,s@rr0r0Ss(ø‡€ðàÐð€Gð2°÷2ò2r"r0có:a€]tRt^]toRtRRRRR/RlltRtVtR#)ÚRecordBatchFileReadera Class for reading Arrow record batch data from the Arrow binary file format Parameters ---------- source : bytes/buffer-like, pyarrow.NativeFile, or file-like Python object Either an in-memory buffer, or a readable file object. If you want to use memory map use MemoryMappedFile as source. footer_offset : int, default None If the file is embedded in some larger file, this is the byte offset to the very end of the file data options : pyarrow.ipc.IpcReadOptions Options for IPC serialization. If None, default values will be used. memory_pool : MemoryPool, default None If None, default memory pool is used. NrrcóB€\V4pVPWW4R7R#)©Ú footer_offsetrrNr)rrr=rrs&&&$$rr ÚRecordBatchFileReader.__init__ps"€ä2°7Ó;ˆØ ‰ 6Ø"ð ö =r"r#©Nr$r,s@rr:r:]s#ø‡€ññ$=¸dð=Ø!÷=ó=r"r:có<a€]tRt^wtoR] 2tRRRR/RltRtVtR#)ÚRecordBatchFileWriterz/Writer to create the Arrow binary file format rNÚmetadatacóB€\V4pVPWW4R7R#)©rrBNr3)rr5r6rrBs&&&$$rr ÚRecordBatchFileWriter.__init__}s€Ü,¨WÓ5ˆØ ‰ 4¨ˆ ÖDr"r#) r%r&r'r(Ú_ipc_file_writer_class_docr)r r*r+r,s@rrArAws3ø‡€ðàÐð €GðE°ðE¸t÷EòEr"rAcóž€V'd0\V\4'g\R\V4 24hV#\P p\ \\PPRR444p\ \\PPRR444'd\Pp\VVR7#)zexpected IpcWriteOptions, got ÚARROW_PRE_0_15_IPC_FORMATÚ0ÚARROW_PRE_1_0_METADATA_VERSION)Úuse_legacy_formatÚmetadata_version) Ú isinstancerÚ TypeErrorÚtyper ÚV5ÚboolÚintÚosÚenvironÚgetÚV4)rrLrKs& rr4r4‚s›€ßܘ'¤?×3Ò3ÜÐ<¼TÀ'»]¸OÐLÓMÐ M؈ä&×)Ñ)Ðä ŒS”—‘—‘Ð ;¸SÓAÓ BÓCðä ŒC”— ‘ —‘Ð?ÀÓEÓ F×GÒGÜ*×-Ñ-ÐÜ Ð->Ø,<ô >ð>r"có”€V'd.\V\4'g\R\V4 24hT;'g \4#)zexpected IpcReadOptions, got )rMrrNrOr2s&rrr‘s9€ß”z '¬>×:Ò:ÜÐ7¼¸W» °ÐGÓHÐHØ × &Ð &”nÓ&Ð&r"rcó€\WVR7#)r2)r0)r5r6rs&&$rÚ new_streamrY—s€Ü " 4Ø+2ô 4ð4r"z5Create an Arrow columnar IPC stream writer instance zS Returns ------- writer : RecordBatchStreamWriter A writer for the given sink rcó€\WVR7#)aß Create reader for Arrow streaming format. Parameters ---------- source : bytes/buffer-like, pyarrow.NativeFile, or file-like Python object Either an in-memory buffer, or a readable file object. options : pyarrow.ipc.IpcReadOptions Options for IPC serialization. If None, default values will be used. memory_pool : MemoryPool, default None If None, default memory pool is used. Returns ------- reader : RecordBatchStreamReader A reader for the given source r)r)rrrs&$$rÚ open_streamr[¨s€ô& # 6Ø/:ô <ðr~sIðó( ã÷A÷A÷A÷AõAõôE˜c×:Ñ:ôEð*)Ðð$Ø õ ð,õ,ðô2˜c×:Ñ:ô2ô=˜C×6Ñ6ô=ô4E˜C×6Ñ6ôEò >ò'ð 4¨ô4ð ðÐðð € Ôð< 4ð<°Tô<ð.S dðS°TôSððÐðð €Ôñ2°Tð2Àtõ2ð6 Tð¸$ôð84¨4ö4r"