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

Method build

datafusion/functions-aggregate/src/array_agg.rs:1560–1574  ·  view source on GitHub ↗
(&self)

Source from the content-addressed store, hash-verified

1558 }
1559
1560 fn build(&self) -> Result<Box<dyn Accumulator>> {
1561 let expr = Arc::new(Column::new("col", 0));
1562 let expr_field = expr.return_field(&self.schema)?;
1563 ArrayAgg::default().accumulator(AccumulatorArgs {
1564 return_field: Arc::clone(&self.return_field),
1565 schema: &self.schema,
1566 expr_fields: &[expr_field],
1567 ignore_nulls: false,
1568 order_bys: &self.order_bys,
1569 is_reversed: false,
1570 name: "",
1571 is_distinct: self.distinct,
1572 exprs: &[expr],
1573 })
1574 }
1575
1576 fn build_two(&self) -> Result<(Box<dyn Accumulator>, Box<dyn Accumulator>)> {
1577 Ok((self.build()?, self.build()?))

Callers 9

regr.rsFile · 0.45
nth_valueFunction · 0.45
evaluateMethod · 0.45
stateMethod · 0.45
build_twoMethod · 0.45
first_valueFunction · 0.45
last_valueFunction · 0.45
bit_and_or_xor.rsFile · 0.45

Calls 3

newFunction · 0.85
return_fieldMethod · 0.45
accumulatorMethod · 0.45

Tested by 1