從批次建立 ArrayStreams

從批次建立 ArrayStreams

用法

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

引數

batches

list() 形式的 nanoarrow_array 物件，或可透過 as_nanoarrow_array() 強制轉換的物件。

schema

一個 nanoarrow_schema 或 NULL，以根據第一個 schema 猜測。

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