refactor: remove last JSON.stringify from query-do, update architecture diagram

- Replace JSON.stringify-based cache key hashing with direct FNV-1a
  feed over query components — no serialization at all in DOs
- Remove bigIntReplacer import from query-do (no longer needed)
- Update excalidraw: NDJSON → columnar binary streaming,
  PageProcessor → streaming operator pipeline,
  JSON return → RPC zero serialization

Author: teamchong

docs/architecture/querymode-architecture.excalidraw

@@ -672,7 +672,7 @@
       "y": 395.1260756922146,
       "width": 149.15985107421875,
       "height": 140,
-      "text": "Query DO — SJC\n\nFooter cache (~4KB/table)\nWASM Engine (Zig SIMD)\nPageProcessor bridge\nVIP eviction (zell)\nCoalesced Range reads\nrefreshStaleTables()\nNDJSON /query/stream",
+      "text": "Query DO — SJC\n\nFooter cache (~4KB/table)\nWASM Engine (Zig SIMD)\nStreaming operator pipeline\nVIP eviction (zell)\nCoalesced Range reads\nrefreshStaleTables()\nColumnar binary streaming",
       "fontSize": 11,
       "fontFamily": 1,
       "textAlign": "center",
@@ -698,7 +698,7 @@
       "roundness": null,
       "updated": 1772498220235,
       "link": null,
-      "originalText": "Query DO — SJC\n\nFooter cache (~4KB/table)\nWASM Engine (Zig SIMD)\nPageProcessor bridge\nVIP eviction (zell)\nCoalesced Range reads\nrefreshStaleTables()\nNDJSON /query/stream",
+      "originalText": "Query DO — SJC\n\nFooter cache (~4KB/table)\nWASM Engine (Zig SIMD)\nStreaming operator pipeline\nVIP eviction (zell)\nCoalesced Range reads\nrefreshStaleTables()\nColumnar binary streaming",
       "autoResize": true,
       "lineHeight": 1.4141414141414141
     },
@@ -760,7 +760,7 @@
       "y": 395,
       "width": 180,
       "height": 140,
-      "text": "Query DO — NRT\n\nFooter cache (~4KB/table)\nWASM Engine (Zig SIMD)\nPageProcessor bridge\nVIP eviction (zell)\nCoalesced Range reads\nrefreshStaleTables()\nNDJSON /query/stream",
+      "text": "Query DO — NRT\n\nFooter cache (~4KB/table)\nWASM Engine (Zig SIMD)\nStreaming operator pipeline\nVIP eviction (zell)\nCoalesced Range reads\nrefreshStaleTables()\nColumnar binary streaming",
       "fontSize": 11,
       "fontFamily": 1,
       "textAlign": "center",
@@ -786,7 +786,7 @@
       "roundness": null,
       "updated": 1772496885793,
       "link": null,
-      "originalText": "Query DO — NRT\n\nFooter cache (~4KB/table)\nWASM Engine (Zig SIMD)\nPageProcessor bridge\nVIP eviction (zell)\nCoalesced Range reads\nrefreshStaleTables()\nNDJSON /query/stream",
+      "originalText": "Query DO — NRT\n\nFooter cache (~4KB/table)\nWASM Engine (Zig SIMD)\nStreaming operator pipeline\nVIP eviction (zell)\nCoalesced Range reads\nrefreshStaleTables()\nColumnar binary streaming",
       "autoResize": true,
       "lineHeight": 1.4141414141414141
     },
@@ -844,7 +844,7 @@
       "y": 395,
       "width": 149.15985107421875,
       "height": 140,
-      "text": "Query DO — AMS\n\nFooter cache (~4KB/table)\nWASM Engine (Zig SIMD)\nPageProcessor bridge\nVIP eviction (zell)\nCoalesced Range reads\nrefreshStaleTables()\nNDJSON /query/stream",
+      "text": "Query DO — AMS\n\nFooter cache (~4KB/table)\nWASM Engine (Zig SIMD)\nStreaming operator pipeline\nVIP eviction (zell)\nCoalesced Range reads\nrefreshStaleTables()\nColumnar binary streaming",
       "fontSize": 11,
       "fontFamily": 1,
       "textAlign": "center",
@@ -870,7 +870,7 @@
       "roundness": null,
       "updated": 1772497096583,
       "link": null,
-      "originalText": "Query DO — AMS\n\nFooter cache (~4KB/table)\nWASM Engine (Zig SIMD)\nPageProcessor bridge\nVIP eviction (zell)\nCoalesced Range reads\nrefreshStaleTables()\nNDJSON /query/stream",
+      "originalText": "Query DO — AMS\n\nFooter cache (~4KB/table)\nWASM Engine (Zig SIMD)\nStreaming operator pipeline\nVIP eviction (zell)\nCoalesced Range reads\nrefreshStaleTables()\nColumnar binary streaming",
       "autoResize": true,
       "lineHeight": 1.4141414141414141
     },
@@ -2421,7 +2421,7 @@
       "y": 833,
       "width": 90,
       "height": 34,
-      "text": "Return JSON\nor NDJSON",
+      "text": "Return RPC result\n(zero serialization)",
       "fontSize": 12,
       "fontFamily": 1,
       "textAlign": "center",
@@ -2447,7 +2447,7 @@
       "roundness": null,
       "updated": 1772496885793,
       "link": null,
-      "originalText": "Return JSON\nor NDJSON",
+      "originalText": "Return RPC result\n(zero serialization)",
       "autoResize": true,
       "lineHeight": 1.4166666666666667
     },

src/query-do.ts

@@ -4,7 +4,7 @@ import { parseFooter, parseColumnMetaFromProtobuf } from "./footer.js";
 import { parseManifest, logicalTypeToDataType } from "./manifest.js";
 import { detectFormat, getParquetFooterLength, parseParquetFooter, parquetMetaToTableMeta } from "./parquet.js";
 import { parseIcebergMetadata, extractParquetPathsFromManifest } from "./iceberg.js";
-import { canSkipPage, bigIntReplacer } from "./decode.js";
+import { canSkipPage } from "./decode.js";
 import { decodeParquetColumnChunk } from "./parquet-decode.js";
 import { instantiateWasm, type WasmEngine } from "./wasm-engine.js";
 import { mergeQueryResults } from "./merge.js";
@@ -591,21 +591,18 @@ export class QueryDO extends DurableObject<Env> {
   }
 
   private queryKey(query: QueryDescriptor): string {
-    const normalized = {
-      t: query.table,
-      f: [...query.filters].sort((a, b) => a.column.localeCompare(b.column) || a.op.localeCompare(b.op)),
-      p: [...query.projections].sort(),
-      s: query.sortColumn, sd: query.sortDirection,
-      l: query.limit,
-      a: query.aggregates, g: query.groupBy,
-    };
-    const str = JSON.stringify(normalized, bigIntReplacer);
-    // FNV-1a hash
+    // FNV-1a hash over query components — no JSON serialization
     let h = 0x811c9dc5;
-    for (let i = 0; i < str.length; i++) {
-      h ^= str.charCodeAt(i);
-      h = Math.imul(h, 0x01000193);
+    const feed = (s: string) => { for (let i = 0; i < s.length; i++) { h ^= s.charCodeAt(i); h = Math.imul(h, 0x01000193); } };
+    feed(query.table);
+    for (const f of [...query.filters].sort((a, b) => a.column.localeCompare(b.column) || a.op.localeCompare(b.op))) {
+      feed(f.column); feed(f.op); feed(String(f.value));
     }
+    for (const p of [...query.projections].sort()) feed(p);
+    if (query.sortColumn) { feed(query.sortColumn); feed(query.sortDirection ?? "asc"); }
+    if (query.limit !== undefined) feed(String(query.limit));
+    if (query.aggregates) for (const a of query.aggregates) { feed(a.fn); feed(a.column); if (a.alias) feed(a.alias); }
+    if (query.groupBy) for (const g of query.groupBy) feed(g);
     return `qr:${query.table}:${(h >>> 0).toString(36)}`;
   }