MCPcopy Create free account
hub / github.com/MaterializeInc/materialize / finish_incremental

Method finish_incremental

src/expr/src/relation.rs:3708–3720  ·  view source on GitHub ↗

Applies finishing actions to the given [`RowCollection`], and reports the total time it took to run. Returns a [`RowCollectionIter`] that contains all of the response data.

(
        &mut self,
        rows: RowCollection,
        max_result_size: u64,
        duration_histogram: &Histogram,
    )

Source from the content-addressed store, hash-verified

3706 /// Returns a [`RowCollectionIter`] that contains all of the response
3707 /// data.
3708 pub fn finish_incremental(
3709 &mut self,
3710 rows: RowCollection,
3711 max_result_size: u64,
3712 duration_histogram: &Histogram,
3713 ) -> Result<RowCollectionIter, String> {
3714 let now = Instant::now();
3715 let result = self.finish_incremental_inner(rows, max_result_size);
3716 let duration = now.elapsed();
3717 duration_histogram.observe(duration.as_secs_f64());
3718
3719 result
3720 }
3721
3722 fn finish_incremental_inner(
3723 &mut self,

Callers

nothing calls this directly

Calls 3

nowFunction · 0.85
observeMethod · 0.45

Tested by

no test coverage detected