From ef7a992e6308d4ada2de7790c38f81671cd2dd1f Mon Sep 17 00:00:00 2001 From: zz_y Date: Tue, 12 May 2026 21:22:11 -0600 Subject: [PATCH] chore(precompute_engine): delete unused RawPassthroughSink MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Phase 5 M2.3.6 cleanup. `RawPassthroughSink` is declared in `output_sink.rs` but never constructed anywhere in the workspace — the only `pass_raw_samples` paths route through other sinks. Drop the dead code (~24 LOC). Co-Authored-By: Claude Opus 4.7 (1M context) --- .../src/precompute_engine/output_sink.rs | 26 ------------------- 1 file changed, 26 deletions(-) diff --git a/data_plane/src/precompute_engine/output_sink.rs b/data_plane/src/precompute_engine/output_sink.rs index 217b597b..05e5a248 100644 --- a/data_plane/src/precompute_engine/output_sink.rs +++ b/data_plane/src/precompute_engine/output_sink.rs @@ -158,32 +158,6 @@ impl OutputSink for SketchIndexSink { } } -/// Output sink for raw passthrough mode — forwards raw samples to the store -/// without sketch computation. In this mode the samples are stored as -/// SumAccumulators (one per sample). -pub struct RawPassthroughSink { - store: Arc, -} - -impl RawPassthroughSink { - pub fn new(store: Arc) -> Self { - Self { store } - } -} - -impl OutputSink for RawPassthroughSink { - fn emit_batch( - &self, - outputs: Vec<(PrecomputedOutput, Box)>, - ) -> Result<(), Box> { - if outputs.is_empty() { - return Ok(()); - } - let _span = debug_span!("store_insert_raw", batch_size = outputs.len()).entered(); - self.store.insert_precomputed_output_batch(outputs) - } -} - /// A capturing sink for testing that stores all emitted outputs. pub struct CapturingOutputSink { pub captured: Mutex)>>,