从批次创建数组流

从批次创建数组流

用法

basic_array_stream(batches, schema = NULL, validate = TRUE)

参数

batches

一个list() 的 nanoarrow_array 对象或可以通过 as_nanoarrow_array() 强制转换的对象。

schema

一个 nanoarrow_schema 或 NULL 用于根据第一个模式进行猜测。

validate

使用 FALSE 跳过验证步骤（即，如果您知道数组有效）。

返回值

一个 nanoarrow_array_stream

示例

(stream <- basic_array_stream(list(data.frame(a = 1, b = 2))))
#> <nanoarrow_array_stream struct<a: double, b: double>>
#>  $ get_schema:function ()  
#>  $ get_next  :function (schema = x$get_schema(), validate = TRUE)  
#>  $ release   :function ()  
as.data.frame(stream$get_next())
#>   a b
#> 1 1 2
stream$get_next()
#> NULL