Skip to content

Commit 30c04d5

Browse files
committed
Use Arrow IPC in Virtual Server API
Signed-off-by: Andrew Stein <steinlink@gmail.com>
1 parent 2d3d46e commit 30c04d5

File tree

12 files changed

+412
-392
lines changed

12 files changed

+412
-392
lines changed

Cargo.lock

Lines changed: 4 additions & 201 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

examples/blocks/src/duckdb/index.js

Lines changed: 24 additions & 24 deletions
Original file line numberDiff line numberDiff line change
@@ -22,39 +22,39 @@ import * as duckdb from "https://cdn.jsdelivr.net/npm/@duckdb/duckdb-wasm@1.33.1
2222

2323
const LOGGER = {
2424
log(entry) {
25-
table2.update([{ timestamp: entry.timestamp, sql: entry.value }]);
25+
// table2.update([{ timestamp: entry.timestamp, sql: entry.value }]);
2626
},
2727
};
2828

2929
const db = await initializeDuckDB();
3030
const server = perspective.createMessageHandler(new DuckDBHandler(db));
3131
const client = await perspective.worker(server);
3232

33-
const logworker = await perspective.worker();
34-
const table2 = await logworker.table(
35-
{ timestamp: "datetime", sql: "string" },
36-
{ name: "logs", limit: 10_000 },
37-
);
33+
// const logworker = await perspective.worker();
34+
// const table2 = await logworker.table(
35+
// { timestamp: "datetime", sql: "string" },
36+
// { name: "logs", limit: 10_000 },
37+
// );
3838

39-
const log_element = document.querySelector("#logger");
40-
log_element.load(logworker);
41-
log_element.restore({
42-
table: "logs",
43-
sort: [["timestamp", "desc"]],
44-
title: "SQL Log",
45-
});
39+
// const log_element = document.querySelector("#logger");
40+
// log_element.load(logworker);
41+
// log_element.restore({
42+
// table: "logs",
43+
// sort: [["timestamp", "desc"]],
44+
// title: "SQL Log",
45+
// });
4646

47-
const log_element2 = document.querySelector("#logger2");
48-
log_element2.load(logworker);
49-
log_element2.restore({
50-
table: "logs",
51-
sort: [["timestamp", "desc"]],
52-
columns: ["sql"],
53-
group_by: ["1s"],
54-
plugin: "Y Bar",
55-
expressions: { "1s": `bucket("timestamp",'1s')` },
56-
title: "SQL Timeline",
57-
});
47+
// const log_element2 = document.querySelector("#logger2");
48+
// log_element2.load(logworker);
49+
// log_element2.restore({
50+
// table: "logs",
51+
// sort: [["timestamp", "desc"]],
52+
// columns: ["sql"],
53+
// group_by: ["1s"],
54+
// plugin: "Y Bar",
55+
// expressions: { "1s": `bucket("timestamp",'1s')` },
56+
// title: "SQL Timeline",
57+
// });
5858

5959
async function initializeDuckDB() {
6060
const JSDELIVR_BUNDLES = duckdb.getJsDelivrBundles();

0 commit comments

Comments
 (0)