Add streaming precompute engine: sketch-based windowed aggregation over Prometheus/VictoriaMetrics remote write

asap-query-engine/Cargo.toml

@@ -39,7 +39,7 @@ flate2 = "1.0"
 async-trait = "0.1"
 xxhash-rust = { version = "0.8", features = ["xxh32", "xxh64"] }
 dsrs = { git = "https://github.com/ProjectASAP/datasketches-rs" }
-sketchlib-rust = { git = "https://github.com/ProjectASAP/sketchlib-rust" }
+sketchlib-rust = { git = "https://github.com/ProjectASAP/sketchlib-rust", rev = "663a1df" }
 base64 = "0.21"
 hex = "0.4"
 sqlparser = "0.59.0"
@@ -55,6 +55,18 @@ zstd = "0.13"
 reqwest = { version = "0.11", features = ["json"] }
 tracing-appender = "0.2"
 
+[[bin]]
+name = "precompute_engine"
+path = "src/bin/precompute_engine.rs"
+
+[[bin]]
+name = "test_e2e_precompute"
+path = "src/bin/test_e2e_precompute.rs"
+
+[[bin]]
+name = "bench_precompute_sketch"
+path = "src/bin/bench_precompute_sketch.rs"
+
 [dev-dependencies]
 tempfile = "3.20.0"
 

asap-query-engine/Dockerfile

@@ -18,8 +18,12 @@ COPY Cargo.toml ./
 COPY Cargo.lock ./
 COPY asap-query-engine/Cargo.toml ./asap-query-engine/
 
-# Create a dummy main.rs to build dependencies
-RUN mkdir -p asap-query-engine/src && echo "fn main() {}" > asap-query-engine/src/main.rs
+# Create dummy Rust targets to build dependencies.
+# Cargo.toml declares explicit bin paths, so they must exist in this cache layer.
+RUN mkdir -p asap-query-engine/src/bin \
+    && echo "fn main() {}" > asap-query-engine/src/main.rs \
+    && echo "fn main() {}" > asap-query-engine/src/bin/precompute_engine.rs \
+    && echo "fn main() {}" > asap-query-engine/src/bin/test_e2e_precompute.rs
 
 # Build dependencies (this layer will be cached)
 WORKDIR /code/asap-query-engine