Re: [Python] Retrieving a RecordBatch from plasma inside a function

2018-02-21 Thread Philipp Moritz
, 0) > >> > >> test1 = [1, 12, 23, 3, 21, 34] > >> test1 = pa.array(test1, pa.int32()) > >> > >> batch = pa.RecordBatch.from_arrays([test1], ['FIELD1']) > >> > >> key = "keynumber1keynumber1" > >> pid = pla

Re: [Python] Retrieving a RecordBatch from plasma inside a function

2018-02-21 Thread Wes McKinney
vance, > Alberto > Da: Philipp Moritz<mailto:pcmor...@gmail.com> > Inviato: venerdì 9 febbraio 2018 00:30 > A: dev@arrow.apache.org<mailto:dev@arrow.apache.org> > Oggetto: Re: [Python] Retrieving a RecordBatch from plasma inside a function > > Thanks! I can indeed reproduc

Re: [Python] Retrieving a RecordBatch from plasma inside a function

2018-02-08 Thread Philipp Moritz
eam, batch.schema) > writer.write_batch(batch) > client.seal(pid) > > batch = retrieve1() > print(batch) > print(batch.schema) > print(batch[0]) > > I hope this helps, > thank you > > Da: Philipp Moritz<mailto:pcmor...@gmail.com> > Inviato: martedì 6 febbraio 20

Re: [Python] Retrieving a RecordBatch from plasma inside a function

2018-02-05 Thread Philipp Moritz
Hey Alberto, Thanks for your message! I'm trying to reproduce it. Can you attach the code you use to write the batch into the store? Also can you say which version of Python and Arrow you are using? On my installation, I get ``` In [*5*]: plasma.ObjectID(bytearray("keynumber1keynumber1", "UTF-