From 17f83a572b4e390f804d5c1560f0d35d52a4e9e2 Mon Sep 17 00:00:00 2001 From: Kyle Barron Date: Mon, 18 Sep 2023 16:38:34 -0600 Subject: [PATCH] fix from api --- tests/js/arrow1.test.ts | 4 ++-- tests/js/arrow2.test.ts | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/tests/js/arrow1.test.ts b/tests/js/arrow1.test.ts index be9bea67..5b730d23 100644 --- 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 index 1606d88f..588b6716 100644 --- 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());