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

Method give

src/compute/src/render/reduce.rs:2542–2548  ·  view source on GitHub ↗
(&mut self, d: &Datum)

Source from the content-addressed store, hash-verified

2540 }
2541
2542 fn give(&mut self, d: &Datum) {
2543 match self {
2544 OneByOneAggrImpls::Basic(i) => i.give(d),
2545 OneByOneAggrImpls::Accumulable(i) => i.give(d),
2546 OneByOneAggrImpls::Hierarchical(i) => i.give(d),
2547 }
2548 }
2549
2550 fn get_current_aggregate<'a>(&self, temp_storage: &'a RowArena) -> Datum<'a> {
2551 // Note that the `reverse` parameter is currently forwarded only for Basic aggregations.

Callers 15

apply_refreshFunction · 0.45
renderFunction · 0.45
renderFunction · 0.45
constructFunction · 0.45
constructFunction · 0.45
constructFunction · 0.45
handle_operatesMethod · 0.45
handle_channelsMethod · 0.45
handle_shutdownMethod · 0.45
handle_parkMethod · 0.45
handle_messagesMethod · 0.45

Calls 7

datum_to_accumulatorFunction · 0.85
get_monoidFunction · 0.85
packerMethod · 0.80
expectMethod · 0.80
plus_equalsMethod · 0.45
cloneMethod · 0.45
pushMethod · 0.45

Tested by

no test coverage detected