Trait tidb_query_aggr::AggrFunctionStateUpdatePartial

[+] Show declaration

pub trait AggrFunctionStateUpdatePartial<TT: EvaluableRef<'static>> {
    unsafe fn update_unsafe(
        &mut self, 
        ctx: &mut EvalContext, 
        value: Option<TT>
    ) -> Result<()>;
    unsafe fn update_repeat_unsafe(
        &mut self, 
        ctx: &mut EvalContext, 
        value: Option<TT>, 
        repeat_times: usize
    ) -> Result<()>;
    unsafe fn update_vector_unsafe(
        &mut self, 
        ctx: &mut EvalContext, 
        phantom_data: Option<TT>, 
        physical_values: TT::ChunkedType, 
        logical_rows: &[usize]
    ) -> Result<()>;
}

[−] Expand description

A helper trait that provides update() and update_vector() over a concrete type, which will be relied in AggrFunctionState.

Required methods

unsafe fn update_unsafe(
    &mut self,
    ctx: &mut EvalContext,
    value: Option<TT>
) -> Result<()>[−]

Updates the internal state giving one row data.

Panics

Panics if the aggregate function does not support the supplied concrete data type as its parameter.

Safety

This function should be called with update macro.

unsafe fn update_repeat_unsafe(
    &mut self,
    ctx: &mut EvalContext,
    value: Option<TT>,
    repeat_times: usize
) -> Result<()>[−]

Repeatedly updates the internal state giving one row data.

Panics

Panics if the aggregate function does not support the supplied concrete data type as its parameter.

Safety

This function should be called with update_repeat_unsafe macro.

unsafe fn update_vector_unsafe(
    &mut self,
    ctx: &mut EvalContext,
    phantom_data: Option<TT>,
    physical_values: TT::ChunkedType,
    logical_rows: &[usize]
) -> Result<()>[−]

Updates the internal state giving multiple rows data.

Panics

Panics if the aggregate function does not support the supplied concrete data type as its parameter.

Safety

This function should be called with update_vector macro.

Implementors

impl<T1, T> AggrFunctionStateUpdatePartial<T1> for AggrFnStateFirst<T> where
    T1: EvaluableRef<'static> + 'static,
    T: EvaluableRef<'static> + 'static,
    VectorValue: VectorValueExt<T::EvaluableType>, [+]

[+] Show hidden undocumented items

unsafe default fn update_unsafe(
    &mut self,
    _ctx: &mut EvalContext,
    _value: Option<T1>
) -> Result<()>

unsafe default fn update_repeat_unsafe(
    &mut self,
    _ctx: &mut EvalContext,
    _value: Option<T1>,
    _repeat_times: usize
) -> Result<()>

unsafe default fn update_vector_unsafe(
    &mut self,
    _ctx: &mut EvalContext,
    _phantom_data: Option<T1>,
    _physical_values: T1::ChunkedType,
    _logical_rows: &[usize]
) -> Result<()>

impl<T> AggrFunctionStateUpdatePartial<T> for AggrFnStateFirst<T> where
    T: EvaluableRef<'static> + 'static,
    VectorValue: VectorValueExt<T::EvaluableType>, [+]

[+] Show hidden undocumented items

unsafe fn update_unsafe(
    &mut self,
    ctx: &mut EvalContext,
    value: Option<T>
) -> Result<()>

unsafe fn update_repeat_unsafe(
    &mut self,
    ctx: &mut EvalContext,
    value: Option<T>,
    repeat_times: usize
) -> Result<()>

unsafe fn update_vector_unsafe(
    &mut self,
    ctx: &mut EvalContext,
    phantom_data: Option<T>,
    physical_values: T::ChunkedType,
    logical_rows: &[usize]
) -> Result<()>

impl<T> AggrFunctionStateUpdatePartial<T> for AggrFnStateCount where
    T: EvaluableRef<'static> + 'static,
    VectorValue: VectorValueExt<T::EvaluableType>, [+]

[+] Show hidden undocumented items

unsafe fn update_unsafe(
    &mut self,
    ctx: &mut EvalContext,
    value: Option<T>
) -> Result<()>

unsafe fn update_repeat_unsafe(
    &mut self,
    ctx: &mut EvalContext,
    value: Option<T>,
    repeat_times: usize
) -> Result<()>

unsafe fn update_vector_unsafe(
    &mut self,
    ctx: &mut EvalContext,
    phantom_data: Option<T>,
    physical_values: T::ChunkedType,
    logical_rows: &[usize]
) -> Result<()>

impl<T: EvaluableRef<'static>, State> AggrFunctionStateUpdatePartial<T> for State where
    State: ConcreteAggrFunctionState<ParameterType = T>, [+]

[+] Show hidden undocumented items

unsafe fn update_unsafe(
    &mut self,
    ctx: &mut EvalContext,
    value: Option<T>
) -> Result<()>

unsafe fn update_repeat_unsafe(
    &mut self,
    ctx: &mut EvalContext,
    value: Option<T>,
    repeat_times: usize
) -> Result<()>

unsafe fn update_vector_unsafe(
    &mut self,
    ctx: &mut EvalContext,
    _phantom_data: Option<T>,
    physical_values: T::ChunkedType,
    logical_rows: &[usize]
) -> Result<()>

impl<T: EvaluableRef<'static>, State> AggrFunctionStateUpdatePartial<T> for State where
    State: ConcreteAggrFunctionState, [+]

[+] Show hidden undocumented items

unsafe default fn update_unsafe(
    &mut self,
    _ctx: &mut EvalContext,
    _value: Option<T>
) -> Result<()>

unsafe default fn update_repeat_unsafe(
    &mut self,
    _ctx: &mut EvalContext,
    _value: Option<T>,
    _repeat_times: usize
) -> Result<()>

unsafe default fn update_vector_unsafe(
    &mut self,
    _ctx: &mut EvalContext,
    _phantom_data: Option<T>,
    _physical_values: T::ChunkedType,
    _logical_rows: &[usize]
) -> Result<()>