Struct PercentileDisc 

pub struct PercentileDisc {
    fractions: Option<f64>,
    return_type: DataType,
}

Fields

fractions: Option<f64>

return_type: DataType

Implementations

impl PercentileDisc

pub fn new(fractions: Option<f64>, return_type: DataType) -> Self

fn add_datum(&self, state: &mut State, datum_ref: DatumRef<'_>)

Trait Implementations

impl AggregateFunction for PercentileDisc

fn return_type(&self) -> DataType

Returns the return type of the aggregate function.

fn create_state(&self) -> Result<AggregateState>

Creates an initial state of the aggregate function.

fn update<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, state: &'life1 mut AggregateState, input: &'life2 StreamChunk, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Update the state with multiple rows.

fn update_range<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, state: &'life1 mut AggregateState, input: &'life2 StreamChunk, range: Range<usize>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Update the state with a range of rows.

fn get_result<'life0, 'life1, 'async_trait>( &'life0 self, state: &'life1 AggregateState, ) -> Pin<Box<dyn Future<Output = Result<Datum>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get aggregate result from the state.

fn encode_state( &self, state: &AggregateState, ) -> Result<Option<ScalarImpl>, ExprError>

Encode the state into a datum that can be stored in state table.

fn decode_state( &self, datum: Option<ScalarImpl>, ) -> Result<AggregateState, ExprError>

Decode the state from a datum in state table.

impl Clone for PercentileDisc

fn clone(&self) -> PercentileDisc

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.