Struct UserDefinedAggregateFunction

pub struct UserDefinedAggregateFunction {
    arg_schema: SchemaRef,
    return_type: DataType,
    return_field: Field,
    state_field: Field,
    runtime: Box<dyn UdfImpl>,
}

Fields

arg_schema: SchemaRef

return_type: DataType

return_field: Field

state_field: Field

runtime: Box<dyn UdfImpl>

Trait Implementations

impl AggregateFunction for UserDefinedAggregateFunction

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<Datum>

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

fn decode_state(&self, datum: Datum) -> Result<AggregateState>

Decode the state from a datum in state table.

fn return_type(&self) -> DataType

Returns the return type of the aggregate function.

impl Debug for UserDefinedAggregateFunction

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

Formats the value using the given formatter.