函数 builderThroughAsyncIterable

  • 将任意 JavaScript 值的 AsyncIterable 转换为 Arrow Vector 序列遵循提供的 options 参数中定义的分块语义。

    此函数返回一个函数,该函数接受要转换的值的 AsyncIterable。 调用时,此函数返回 Vector<T> 的 AsyncIterator。

    生成的 AsyncIterator<Vector<T>> 根据 options 参数中指定的 queueingStrategyhighWaterMark 产生向量。

    • 如果 queueingStrategy"count"(或省略),则 AsyncIterator<Vector<T>> 将刷新底层 Builder(并产生新的 Vector<T>),一旦 Builder 的 length 达到或超过提供的 highWaterMark
    • 如果 queueingStrategy"bytes",则 AsyncIterator<Vector<T>> 将刷新底层 Builder(并产生新的 Vector<T>),一旦其 byteLength 达到或超过提供的 highWaterMark

    类型参数

    参数

    • options: IterableBuilderOptions<T, TNull>

      确定要创建的 Builder 和要使用的分块语义的属性对象。

    返回 ThroughAsyncIterable<T, TNull>

    一个函数,它接受要写入的值的 JavaScript AsyncIterable,并返回一个 AsyncIterator,该迭代器根据 options 参数中定义的分块语义产生向量。