Struct datafusion_physical_expr::expressions::ApproxPercentileContWithWeight

pub struct ApproxPercentileContWithWeight { /* private fields */ }

APPROX_PERCENTILE_CONT_WITH_WEIGTH aggregate expression

Implementations

impl ApproxPercentileContWithWeight

pub fn new(
    expr: Vec<Arc<dyn PhysicalExpr>>,
    name: impl Into<String>,
    return_type: DataType
) -> Result<Self>

Create a new ApproxPercentileContWithWeight aggregate function.

Trait Implementations

impl AggregateExpr for ApproxPercentileContWithWeight

fn state_fields(&self) -> Result<Vec<Field>>

See [TDigest::to_scalar_state()] for a description of the serialised state.

fn as_any(&self) -> &dyn Any

Returns the aggregate expression as Any so that it can be downcast to a specific implementation.

fn field(&self) -> Result<Field>

the field of the final result of this aggregation.

fn expressions(&self) -> Vec<Arc<dyn PhysicalExpr>>

expressions that are passed to the Accumulator. Single-column aggregations such as sum return a single value, others (e.g. cov) return many.

fn create_accumulator(&self) -> Result<Box<dyn Accumulator>>

the accumulator used to accumulate values from the expressions. the accumulator expects the same number of arguments as expressions and must return states with the same description as state_fields

fn name(&self) -> &str

Human readable name such as "MIN(c2)". The default implementation returns placeholder text.

fn row_accumulator_supported(&self) -> bool

If the aggregate expression is supported by row format

fn create_row_accumulator(
    &self,
    _start_index: usize
) -> Result<Box<dyn RowAccumulator>>

RowAccumulator to access/update row-based aggregation state in-place. Currently, row accumulator only supports states of fixed-sized type.

impl Debug for ApproxPercentileContWithWeight

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.