@apache-arrow/ts - npm Package Compare versions

Comparing version 8.0.0 to 9.0.0

ipc/reader.ts

@@ -150,3 +150,3 @@ // Licensed to the Apache Software Foundation (ASF) under one
     public static from<T extends TypeMap = any>(source: FromArg3): Promise<RecordBatchFileReader<T> | RecordBatchStreamReader<T>>;
-    public static from<T extends TypeMap = any>(source: FromArg4): Promise<RecordBatchFileReader<T> | AsyncRecordBatchReaders<T>>;
+    public static from<T extends TypeMap = any>(source: FromArg4): Promise<AsyncRecordBatchFileReader<T> | AsyncRecordBatchStreamReader<T>>;
     public static from<T extends TypeMap = any>(source: FromArg5): Promise<AsyncRecordBatchFileReader<T> | AsyncRecordBatchStreamReader<T>>;
@@ -153,0 +153,0 @@ /** @nocollapse */

ipc/serialization.ts

@@ -21,5 +21,13 @@ // Licensed to the Apache Software Foundation (ASF) under one
 import { isPromise } from '../util/compat.js';
-import { FromArg0, FromArg1, FromArg2, FromArg3, FromArg4, FromArg5, RecordBatchReader } from './reader.js';
+import {
+    FromArg0, FromArg1, FromArg2, FromArg3, FromArg4, FromArg5,
+    RecordBatchReader,
+    RecordBatchFileReader, RecordBatchStreamReader,
+    AsyncRecordBatchFileReader, AsyncRecordBatchStreamReader
+} from './reader.js';
 import { RecordBatchFileWriter, RecordBatchStreamWriter } from './writer.js';
 
+type RecordBatchReaders<T extends TypeMap = any> = RecordBatchFileReader<T> | RecordBatchStreamReader<T>;
+type AsyncRecordBatchReaders<T extends TypeMap = any> = AsyncRecordBatchFileReader<T> | AsyncRecordBatchStreamReader<T>;
+
 /**
@@ -31,9 +39,15 @@ * Deserialize the IPC format into a {@link Table}. This function is a
 export function tableFromIPC<T extends TypeMap = any>(source: FromArg1): Promise<Table<T>>;
-export function tableFromIPC<T extends TypeMap = any>(source: FromArg3 | FromArg4 | FromArg5): Promise<Table<T>> | Table<T>;
+export function tableFromIPC<T extends TypeMap = any>(source: FromArg3 | FromArg4 | FromArg5): Promise<Table<T>>;
+export function tableFromIPC<T extends TypeMap = any>(source: RecordBatchReaders<T>): Table<T>;
+export function tableFromIPC<T extends TypeMap = any>(source: AsyncRecordBatchReaders<T>): Promise<Table<T>>;
+export function tableFromIPC<T extends TypeMap = any>(source: RecordBatchReader<T>): Table<T> | Promise<Table<T>>;
 export function tableFromIPC<T extends TypeMap = any>(input: any): Table<T> | Promise<Table<T>> {
-    const reader = RecordBatchReader.from<T>(input);
-    if (isPromise(reader)) {
-        return (async () => new Table(await (await reader).readAll()))();
+    const reader = RecordBatchReader.from<T>(input) as RecordBatchReader<T> | Promise<RecordBatchReader<T>>;
+    if (isPromise<RecordBatchReader<T>>(reader)) {
+        return reader.then((reader) => tableFromIPC(reader)) as Promise<Table<T>>;
     }
-    return new Table(reader.readAll());
+    if (reader.isAsync()) {
+        return (reader as AsyncRecordBatchReaders<T>).readAll().then((xs) => new Table(xs));
+    }
+    return new Table((reader as RecordBatchReaders<T>).readAll());
 }
@@ -40,0 +54,0 @@

package.json

 {
-  "version": "8.0.0",
+  "version": "9.0.0",
   "name": "@apache-arrow/ts",
@@ -31,3 +31,3 @@ "browser": "Arrow.dom.ts",
     "@types/flatbuffers": "*",
-    "@types/node": "^17.0.24",
+    "@types/node": "^17.0.36",
     "@types/command-line-args": "5.2.0",
@@ -41,4 +41,4 @@ "@types/command-line-usage": "5.0.2",
     "pad-left": "^2.1.0",
-    "tslib": "^2.3.1"
+    "tslib": "^2.4.0"
   }
 }

table.ts

@@ -227,3 +227,6 @@ // Licensed to the Apache Software Foundation (ASF) under one
     public [Symbol.iterator]() {
-        return iteratorVisitor.visit(new Vector(this.data)) as IterableIterator<Struct<T>['TValue']>;
+        if (this.batches.length > 0) {
+            return iteratorVisitor.visit(new Vector(this.data)) as IterableIterator<Struct<T>['TValue']>;
+        }
+        return (new Array(0))[Symbol.iterator]();
     }
@@ -230,0 +233,0 @@

vector.ts

@@ -70,3 +70,3 @@ // Licensed to the Apache Software Foundation (ASF) under one
             : input as Data<T>[];
-        if (data.some((x) => !(x instanceof Data))) {
+        if (data.length === 0 || data.some((x) => !(x instanceof Data))) {
             throw new TypeError('Vector constructor expects an Array of Data instances.');
@@ -73,0 +73,0 @@ }

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

888112

increased by0.88%

Lines of code

16178

increased by0.1%

Dependency changes

• Updated@types/node@^17.0.36

• Updatedtslib@^2.4.0