From d1acbbea93cc1a497ab852299ca86bb269723632 Mon Sep 17 00:00:00 2001 From: "H. Thomson Comer" Date: Thu, 16 Jun 2022 16:42:42 -0500 Subject: [PATCH 1/3] README.md: Typo messing with demos. --- README.md | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/README.md b/README.md index 6754db5..76b3bea 100644 --- a/README.md +++ b/README.md @@ -64,7 +64,7 @@ fastify.get(`/data`, (request, reply) => { }); (async () => { - const res = await fastfiy.inject({ + const res = await fastify.inject({ url: '/data', method: `GET`, headers: { 'accepts': `application/octet-stream` } @@ -110,7 +110,7 @@ fastify.post(`/update`, (request, reply) => { }); (async () => { - const res = await fastfiy.inject({ + const res = await fastify.inject({ url: '/update', method: `POST`, headers: { 'accepts': `text/plain; charset=utf-8`, 'content-type': `application/octet-stream` @@ -133,7 +133,7 @@ fastify.post(`/avg_floats`, (request, reply) => { (async () => { const writer = RecordBatchStreamWriter.writeAll(demoData()); - const averages = await fastfiy.inject({ + const averages = await fastify.inject({ url: '/avg_floats', method: `POST`, payload: writer.toNodeStream(), headers: { From 21496370cdef217f91cdb5411f68df9a68537f61 Mon Sep 17 00:00:00 2001 From: "H. Thomson Comer" Date: Thu, 16 Jun 2022 16:45:43 -0500 Subject: [PATCH 2/3] Also do tableFromArrays --- README.md | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/README.md b/README.md index 76b3bea..b19618d 100644 --- a/README.md +++ b/README.md @@ -85,7 +85,7 @@ function* demoData(batchLen = 10, numBatches = 5) { (() => { for (let i = -1; ++i < batchLen; str[i] = randstr((num[i] = rand() * (2 ** 4)) | 0)); })(); - const table = tableFromArrays({ + const table = tableFromArray({ strings: vectorFromArray(str), floats: vectorFromArray(num) }); @@ -151,7 +151,7 @@ function averageFloatCols(table) { .map((f) => table.getChild(f.name)) .map((xs) => Iterable.from(xs).average()) .map((avg) => vectorFromArray(new Float32Array([avg]))) - return tableFromArrays(names.reduce((xs, name, i) => ({ + return tableFromArray(names.reduce((xs, name, i) => ({ ...xs, [name]: averages[i] }), {})); } From 7ed07032638a461777c48cb00752302be8dbf3c3 Mon Sep 17 00:00:00 2001 From: "H. Thomson Comer" Date: Thu, 16 Jun 2022 16:51:46 -0500 Subject: [PATCH 3/3] Not that tableFromArrays --- README.md | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/README.md b/README.md index b19618d..d1e7c40 100644 --- a/README.md +++ b/README.md @@ -52,6 +52,7 @@ const Fastify = require('fastify'); const arrowPlugin = require('fastify-arrow'); const fastify = Fastify().register(require('fastify-arrow')); const { + tableFromArrays, tableFromIPC, vectorFromArray, Utf8Vector, FloatVector, RecordBatchStreamWriter, @@ -85,7 +86,7 @@ function* demoData(batchLen = 10, numBatches = 5) { (() => { for (let i = -1; ++i < batchLen; str[i] = randstr((num[i] = rand() * (2 ** 4)) | 0)); })(); - const table = tableFromArray({ + const table = tableFromArrays({ strings: vectorFromArray(str), floats: vectorFromArray(num) }); @@ -151,7 +152,7 @@ function averageFloatCols(table) { .map((f) => table.getChild(f.name)) .map((xs) => Iterable.from(xs).average()) .map((avg) => vectorFromArray(new Float32Array([avg]))) - return tableFromArray(names.reduce((xs, name, i) => ({ + return tableFromArrays(names.reduce((xs, name, i) => ({ ...xs, [name]: averages[i] }), {})); }