Struct datafusion::physical_expr::expressions::ApproxPercentileCont

pub struct ApproxPercentileCont { /* private fields */ }

APPROX_PERCENTILE_CONT aggregate expression

Implementations

impl ApproxPercentileCont

pub fn new( expr: Vec<Arc<dyn PhysicalExpr>, Global>, name: impl Into<String>, input_data_type: DataType ) -> Result<ApproxPercentileCont, DataFusionError>

Create a new ApproxPercentileCont aggregate function.

pub fn new_with_max_size( expr: Vec<Arc<dyn PhysicalExpr>, Global>, name: impl Into<String>, input_data_type: DataType ) -> Result<ApproxPercentileCont, DataFusionError>

Create a new ApproxPercentileCont aggregate function.

Trait Implementations

impl AggregateExpr for ApproxPercentileCont

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

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

fn as_any(&self) -> &(dyn Any + 'static)

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

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

the field of the final result of this aggregation.

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

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, Global>, DataFusionError>

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 order_bys(&self) -> Option<&[PhysicalSortExpr]>

Order by requirements for the aggregate function By default it is None (there is no requirement) Order-sensitive aggregators, such as FIRST_VALUE(x ORDER BY y) should implement this

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, Global>, DataFusionError>

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

fn reverse_expr(&self) -> Option<Arc<dyn AggregateExpr>>

Construct an expression that calculates the aggregate in reverse. Typically the “reverse” expression is itself (e.g. SUM, COUNT). For aggregates that do not support calculation in reverse, returns None (which is the default value).

fn create_sliding_accumulator( &self ) -> Result<Box<dyn Accumulator, Global>, DataFusionError>

Creates accumulator implementation that supports retract

impl Debug for ApproxPercentileCont

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

Formats the value using the given formatter.

impl PartialEq<ApproxPercentileCont> for ApproxPercentileCont

fn eq(&self, other: &ApproxPercentileCont) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl PartialEq<dyn Any> for ApproxPercentileCont

fn eq(&self, other: &(dyn Any + 'static)) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.