MCPcopy Create free account
hub / github.com/apache/datafusion / update_batch

Method update_batch

datafusion/functions-aggregate/src/string_agg.rs:252–254  ·  view source on GitHub ↗
(&mut self, values: &[ArrayRef])

Source from the content-addressed store, hash-verified

250
251impl Accumulator for StringAggAccumulator {
252 fn update_batch(&mut self, values: &[ArrayRef]) -> Result<()> {
253 self.array_agg_acc.update_batch(&filter_index(values, 1))
254 }
255
256 fn evaluate(&mut self) -> Result<ScalarValue> {
257 let scalar = self.array_agg_acc.evaluate()?;

Callers 15

merge_batchMethod · 0.45
no_duplicates_distinctFunction · 0.45
duplicates_no_distinctFunction · 0.45
duplicates_distinctFunction · 0.45
groups_basicFunction · 0.45
groups_with_nullsFunction · 0.45
groups_with_filterFunction · 0.45

Calls 8

filter_indexFunction · 0.85
apply_filter_as_nullsFunction · 0.85
append_stringsMethod · 0.80
resizeMethod · 0.45
data_typeMethod · 0.45
append_batchMethod · 0.45
iterMethod · 0.45
firstMethod · 0.45

Tested by 15

no_duplicates_distinctFunction · 0.36
duplicates_no_distinctFunction · 0.36
duplicates_distinctFunction · 0.36
groups_basicFunction · 0.36
groups_with_nullsFunction · 0.36
groups_with_filterFunction · 0.36
groups_emit_firstFunction · 0.36