Struct datafusion::physical_plan::udaf::AggregateUDF
source · [−]pub struct AggregateUDF {
pub name: String,
pub signature: Signature,
pub return_type: Arc<dyn Fn(&[DataType]) + Sync + Send + 'static>,
pub accumulator: Arc<dyn Fn(&DataType) + Sync + Send + 'static>,
pub state_type: Arc<dyn Fn(&DataType) + Sync + Send + 'static>,
}
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: Arc<dyn Fn(&[DataType]) + Sync + Send + 'static>
Return type
accumulator: Arc<dyn Fn(&DataType) + Sync + Send + 'static>
actual implementation
state_type: Arc<dyn Fn(&DataType) + Sync + Send + 'static>
the accumulator’s state’s description as a function of the return type
Implementations
sourceimpl AggregateUDF
impl AggregateUDF
Trait Implementations
sourceimpl Clone for AggregateUDF
impl Clone for AggregateUDF
sourcefn clone(&self) -> AggregateUDF
fn clone(&self) -> AggregateUDF
Returns a copy of the value. Read more
1.0.0 · sourcefn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moresourceimpl Debug for AggregateUDF
impl Debug for AggregateUDF
sourceimpl Hash for AggregateUDF
impl Hash for AggregateUDF
sourceimpl PartialEq<AggregateUDF> for AggregateUDF
impl PartialEq<AggregateUDF> for AggregateUDF
sourcefn eq(&self, other: &AggregateUDF) -> bool
fn eq(&self, other: &AggregateUDF) -> bool
impl Eq for AggregateUDF
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
sourceimpl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> CallHasher for Twhere
T: Hash + ?Sized,
impl<T> CallHasher for Twhere
T: Hash + ?Sized,
sourceimpl<Q, K> Equivalent<K> for Qwhere
Q: Eq + ?Sized,
K: Borrow<Q> + ?Sized,
impl<Q, K> Equivalent<K> for Qwhere
Q: Eq + ?Sized,
K: Borrow<Q> + ?Sized,
sourcefn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key
and return true
if they are equal.