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
AsyncIterableof arbitrary JavaScript values into a sequence of Arrow Vectoroptionsargument.This function returns a function that accepts an
AsyncIterableof values to transform. When called, this function returns an AsyncIterator ofVector<T>.The resulting
AsyncIterator<Vector<T>>yields Vectors based on thequeueingStrategyandhighWaterMarkspecified in theoptionsargument.queueingStrategyis"count"(or omitted), TheAsyncIterator<Vector<T>>will flush the underlyingBuilder(and yield a newVector<T>) once the Builder'slengthreaches or exceeds the suppliedhighWaterMark.queueingStrategyis"bytes", theAsyncIterator<Vector<T>>will flush the underlyingBuilder(and yield a newVector<T>) once itsbyteLengthreaches or exceeds the suppliedhighWaterMark.