假设我importpyarrowaspaca=pa.chunked_array([['a','b','b','c']])print(ca)<pyarrow.lib.ChunkedArrayobjectat0x7fc938bcea70>[["a","b","b","

使用R，我创建了一个Parquet文件，其中包含一个data.table作为主要数据，另一个data.table作为元数据。library(data.table)library(arrow)dt=data.table(x=c(1,2,3),y=c("a","b","c"))dt2=data.table(a=22222,b=45555)attr(dt,&

阅读pyarrowIPC文档后，我的印象是RecordBatchStreamReader会读取流直到完成（最后的0-s，是通过关闭流编写器写入的）。但是我看到reader很快就停止了，这不是我期望看到的。下面的示例开始在一个进程中写入文件流，并在延迟后开始在另一个进程中读取该文件流。我希望读者能