ó ßüÚ\c@`sĖddlmZmZmZddlmZmZddlZejdkr\e dƒ‚nej ej ƒd„ƒZ ej ej ƒd„ƒZ ej ejƒd „ƒZej ejƒd „ƒZdS( i(tprint_functiontdivisiontabsolute_importi(tdask_serializetdask_deserializeNs0.10sLNeed pyarrow >= 0.10 . See https://arrow.apache.org/docs/python/install.htmlcC`s]tjƒ}tj||jƒ}|j|ƒ|jƒ|jƒ}i}|g}||fS(N(tpyarrowtBufferOutputStreamtRecordBatchStreamWritertschemat write_batchtclosetgetvalue(tbatchtsinktwritertbuftheadertframes((s9lib/python2.7/site-packages/distributed/protocol/arrow.pytserialize_batchs     cC`s,|d}tjtj|ƒƒ}|jƒS(Ni(RtRecordBatchStreamReadert BufferReadertread_next_batch(RRtblobtreader((s9lib/python2.7/site-packages/distributed/protocol/arrow.pytdeserialize_batchs cC`s]tjƒ}tj||jƒ}|j|ƒ|jƒ|jƒ}i}|g}||fS(N(RRRRt write_tableR R (ttblR RRRR((s9lib/python2.7/site-packages/distributed/protocol/arrow.pytserialize_table!s     cC`s,|d}tjtj|ƒƒ}|jƒS(Ni(RRRtread_all(RRRR((s9lib/python2.7/site-packages/distributed/protocol/arrow.pytdeserialize_table-s (t __future__RRRt serializeRRRt __version__t ImportErrortregistert RecordBatchRRtTableRR(((s9lib/python2.7/site-packages/distributed/protocol/arrow.pyts