Struct datafusion::physical_plan::udaf::AggregateUDF [−][src]
pub struct AggregateUDF {
pub name: String,
pub signature: Signature,
pub return_type: ReturnTypeFunction,
pub accumulator: AccumulatorFunctionImplementation,
pub state_type: StateTypeFunction,
}
Expand description
Logical representation of a user-defined aggregate function (UDAF) A UDAF is different from a UDF in that it is stateful across batches.
Fields
name: String
name
signature: Signature
signature
return_type: ReturnTypeFunction
Return type
accumulator: AccumulatorFunctionImplementation
actual implementation
state_type: StateTypeFunction
the accumulator’s state’s description as a function of the return type
Implementations
pub fn new(
name: &str,
signature: &Signature,
return_type: &ReturnTypeFunction,
accumulator: &AccumulatorFunctionImplementation,
state_type: &StateTypeFunction
) -> Self
pub fn new(
name: &str,
signature: &Signature,
return_type: &ReturnTypeFunction,
accumulator: &AccumulatorFunctionImplementation,
state_type: &StateTypeFunction
) -> Self
Create a new AggregateUDF
Trait Implementations
This method returns an ordering between self
and other
values if one exists. Read more
This method tests less than (for self
and other
) and is used by the <
operator. Read more
This method tests less than or equal to (for self
and other
) and is used by the <=
operator. Read more
This method tests greater than (for self
and other
) and is used by the >
operator. Read more
Auto Trait Implementations
impl !RefUnwindSafe for AggregateUDF
impl Send for AggregateUDF
impl Sync for AggregateUDF
impl Unpin for AggregateUDF
impl !UnwindSafe for AggregateUDF
Blanket Implementations
Mutably borrows from an owned value. Read more