fix from api

kylebarron · Sep 18, 2023 · 17f83a5 · 17f83a5
1 parent 220a13c
commit 17f83a5
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/tests/js/arrow1.test.ts b/tests/js/arrow1.test.ts
@@ -43,7 +43,7 @@ it("read-write-read round trip (with writer properties)", async (t) => {
   const writerProperties = new wasm.WriterPropertiesBuilder().build();
 
   const parquetBuffer = wasm.writeParquet(
-    wasm.Table.fromIPC(tableToIPC(initialTable, "stream")),
+    wasm.Table.fromIPCStream(tableToIPC(initialTable, "stream")),
     writerProperties
   );
   const table = tableFromIPC(wasm.readParquet(parquetBuffer).intoIPCStream());
@@ -58,7 +58,7 @@ it("read-write-read round trip (no writer properties provided)", async (t) => {
   const initialTable = tableFromIPC(wasm.readParquet(arr).intoIPCStream());
 
   const parquetBuffer = wasm.writeParquet(
-    wasm.Table.fromIPC(tableToIPC(initialTable, "stream"))
+    wasm.Table.fromIPCStream(tableToIPC(initialTable, "stream"))
   );
   const table = tableFromIPC(wasm.readParquet(parquetBuffer).intoIPCStream());
 

diff --git a/tests/js/arrow2.test.ts b/tests/js/arrow2.test.ts
@@ -42,7 +42,7 @@ it("read-write-read round trip (with writer properties)", () => {
   const writerProperties = new wasm.WriterPropertiesBuilder().build();
 
   const parquetBuffer = wasm.writeParquet(
-    wasm.Table.fromIPC(tableToIPC(initialTable, "file")),
+    wasm.Table.fromIPCStream(tableToIPC(initialTable, "stream")),
     writerProperties
   );
   const table = tableFromIPC(wasm.readParquet(parquetBuffer).intoIPCStream());
@@ -57,7 +57,7 @@ it("read-write-read round trip (no writer properties provided)", async (t) => {
   const initialTable = tableFromIPC(wasm.readParquet(arr).intoIPCStream());
 
   const parquetBuffer = wasm.writeParquet(
-    wasm.Table.fromIPC(tableToIPC(initialTable, "file"))
+    wasm.Table.fromIPCStream(tableToIPC(initialTable, "stream"))
   );
   const table = tableFromIPC(wasm.readParquet(parquetBuffer).intoIPCStream());