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());