Transform an AsyncIterable of arbitrary JavaScript values into a
sequence of Arrow Vector following the chunking semantics defined in
the supplied options argument.
This function returns a function that accepts an AsyncIterable of values to
transform. When called, this function returns an AsyncIterator of Vector<T>.
The resulting AsyncIterator<Vector<T>> yields Vectors based on the
queueingStrategy and highWaterMark specified in the options argument.
If queueingStrategy is "count" (or omitted), The AsyncIterator<Vector<T>>
will flush the underlying Builder (and yield a new Vector<T>) once the
Builder's length reaches or exceeds the supplied highWaterMark.
If queueingStrategy is "bytes", the AsyncIterator<Vector<T>> will flush
the underlying Builder (and yield a new Vector<T>) once its byteLength
reaches or exceeds the supplied highWaterMark.
A function which accepts a JavaScript AsyncIterable of values
to write, and returns an AsyncIterator that yields Vectors
according to the chunking semantics defined in the options
argument.
Transform an following the chunking semantics defined in
the supplied
AsyncIterable
of arbitrary JavaScript values into a sequence of Arrow Vectoroptions
argument.This function returns a function that accepts an
AsyncIterable
of values to transform. When called, this function returns an AsyncIterator ofVector<T>
.The resulting
AsyncIterator<Vector<T>>
yields Vectors based on thequeueingStrategy
andhighWaterMark
specified in theoptions
argument.queueingStrategy
is"count"
(or omitted), TheAsyncIterator<Vector<T>>
will flush the underlyingBuilder
(and yield a newVector<T>
) once the Builder'slength
reaches or exceeds the suppliedhighWaterMark
.queueingStrategy
is"bytes"
, theAsyncIterator<Vector<T>>
will flush the underlyingBuilder
(and yield a newVector<T>
) once itsbyteLength
reaches or exceeds the suppliedhighWaterMark
.