Stream objects as Arrow arrays

Usage

narrow_array_stream(list_of_array = list(), schema = NULL, validate = TRUE)

narrow_array_stream_collect(array_stream, ptype = NULL)

narrow_array_stream_get_schema(array_stream)

narrow_array_stream_get_next(array_stream, validate = TRUE)

as_narrow_array_stream(x, ...)

# S3 method for narrow_array_stream
as_narrow_array_stream(x, ...)

# S3 method for list
as_narrow_array_stream(x, ...)

# S3 method for `function`
as_narrow_array_stream(x, ...)

# S3 method for default
as_narrow_array_stream(x, ...)

# S3 method for narrow_array
as_narrow_array_stream(x, ...)

Arguments

list_of_array: A list() of narrow_array()s.
schema: The schema for all the arrays in list_of_array.
validate: Use FALSE to skip validation of arrays in list_of_array.
array_stream: An object of class "narrow_array_stream"
ptype: An R object to use as a prototype
x: An R object to convert to an Arrow Stream
...: Passed to S3 methods

Value

An object of class "narrow_array_stream"