refactor: switch consumer imports to asap_sketchlib::sketches::*

Update PR #307 against the reorganized asap_sketchlib (PR #36) — runtime
sketches now live in the existing src/sketches/ layout (single home per
sketch concept), not under a separate `asap::` namespace.

Path swaps in asap-query-engine (legacy fork; smaller surface than
ASAPQuery-backend — no DDSketch / CountSketch / HllSketch accumulators):
- asap_sketchlib::asap::count_min::*            → ::sketches::countmin::*
- asap_sketchlib::asap::kll::*                  → ::sketches::kll::*
- asap_sketchlib::asap::count_min_with_heap::*  → ::sketches::cms_heap::*
- asap_sketchlib::asap::hydra_kll::*            → ::sketches::hydra_kll::*
- asap_sketchlib::asap::set_aggregator::*       → ::sketches::set_aggregator::*
- asap_sketchlib::asap::delta_set_aggregator::* → ::sketches::delta_set_aggregator::*
- asap_sketchlib::asap::config::*               → ::asap_runtime::*

Rename carried through:
- HeapItem → CmsHeapItem (avoids common::input::HeapItem collision)

main.rs aliases asap_runtime as `config` so existing clap-derive references
keep working.

Tests:
- cargo check -p query_engine_rust                       → clean
- cargo test -p query_engine_rust --lib precompute_operators → 87 passed, 0 failed

Depends on ProjectASAP/asap_sketchlib#36 (force-pushed e473ccc).

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>

Author: zzylol

Cargo.lock

@@ -38,7 +38,6 @@ urlencoding = "2.1"
 flate2 = "1.0"
 async-trait = "0.1"
 xxhash-rust = { version = "0.8", features = ["xxh32", "xxh64"] }
-dsrs = { git = "https://github.com/ProjectASAP/datasketches-rs", rev = "d748ec75c80fff21f7b24897244dd1c895df2e9a" }
 base64 = "0.21"
 hex = "0.4"
 sqlparser = "0.59.0"
@@ -59,7 +58,7 @@ tracing-appender = "0.2"
 arc-swap = "1"
 csv = "1"
 elastic_dsl_utilities.workspace = true
-asap_sketchlib = { git = "https://github.com/ProjectASAP/asap_sketchlib", branch = "refactor/adopt-sketch-core-modules", features = ["asap-cli"] }
+asap_sketchlib = { git = "https://github.com/ProjectASAP/asap_sketchlib", branch = "refactor/adopt-sketch-core-modules" }
 
 [[bin]]
 name = "precompute_engine"
@@ -78,7 +77,6 @@ name = "e2e_quickstart_resource_test"
 path = "src/bin/e2e_quickstart_resource_test.rs"
 
 [dev-dependencies]
-ctor = "0.2"
 tempfile = "3.20.0"
 criterion = { version = "0.5", features = ["html_reports"] }
 
@@ -93,4 +91,3 @@ default = []
 lock_profiling = []
 # Enable extra debugging output
 extra_debugging = []
-sketchlib-tests = []

asap-query-engine/Cargo.toml

@@ -1,16 +1,3 @@
-#[cfg(test)]
-#[ctor::ctor]
-fn init_sketch_backend_for_tests() {
-    #[cfg(feature = "sketchlib-tests")]
-    let _ = asap_sketchlib::asap::config::configure(
-        asap_sketchlib::asap::config::ImplMode::Sketchlib,
-        asap_sketchlib::asap::config::ImplMode::Legacy,
-        asap_sketchlib::asap::config::ImplMode::Sketchlib,
-    );
-    #[cfg(not(feature = "sketchlib-tests"))]
-    asap_sketchlib::asap::config::force_legacy_mode_for_tests();
-}
-
 pub mod data_model;
 pub mod drivers;
 pub mod engines;

asap-query-engine/src/lib.rs

@@ -5,8 +5,6 @@ use std::sync::{Arc, RwLock};
 use tokio::signal;
 use tracing::{debug, error, info, warn};
 
-use asap_sketchlib::asap::config::{self, ImplMode};
-
 use asap_types::streaming_config::StreamingConfig;
 use query_engine_rust::data_model::enums::{
     CleanupPolicy, InputFormat, LockStrategy, StreamingEngine,
@@ -115,18 +113,6 @@ struct Args {
     #[arg(long)]
     promsketch_config: Option<String>,
 
-    /// Backend implementation for Count-Min Sketch (legacy | sketchlib)
-    #[arg(long, value_enum, default_value_t = config::DEFAULT_CMS_IMPL)]
-    sketch_cms_impl: ImplMode,
-
-    /// Backend implementation for KLL Sketch (legacy | sketchlib)
-    #[arg(long, value_enum, default_value_t = config::DEFAULT_KLL_IMPL)]
-    sketch_kll_impl: ImplMode,
-
-    /// Backend implementation for Count-Min-With-Heap (legacy | sketchlib)
-    #[arg(long, value_enum, default_value_t = config::DEFAULT_CMWH_IMPL)]
-    sketch_cmwh_impl: ImplMode,
-
     /// Enable OTLP metrics ingest (gRPC + HTTP)
     #[arg(long)]
     enable_otel_ingest: bool,
@@ -206,14 +192,6 @@ struct Args {
 async fn main() -> Result<()> {
     let args = Args::parse();
 
-    // Configure sketch-core backends before any sketch operations.
-    config::configure(
-        args.sketch_cms_impl,
-        args.sketch_kll_impl,
-        args.sketch_cmwh_impl,
-    )
-    .expect("sketch backend already initialised");
-
     // Create output directory
     fs::create_dir_all(&args.output_dir)?;
 

asap-query-engine/src/main.rs

@@ -776,7 +776,7 @@ mod tests {
     use crate::precompute_operators::datasketches_kll_accumulator::DatasketchesKLLAccumulator;
     use crate::precompute_operators::multiple_sum_accumulator::MultipleSumAccumulator;
     use crate::precompute_operators::sum_accumulator::SumAccumulator;
-    use asap_sketchlib::asap::kll::KllSketch;
+    use asap_sketchlib::sketches::kll::KllSketch;
     use asap_types::enums::{AggregationType, WindowType};
 
     fn make_agg_config(