pub struct DeclareAggregateProcedure { /* private fields */ }Expand description
Implementation of uni.plugin.declareAggregate.
Parses three Cypher expression bodies (init / update /
finalize) at declare time, persists a
DeclaredPlugin record with kind "aggregate", and registers
a synthetic uni_plugin::traits::aggregate::AggregatePluginFn
(DeclaredAggregateFn) into the shared registry. The new
aggregate becomes invokable from Cypher (RETURN myAgg(x)) via
the planner fall-through to
crate::query::df_udaf_plugin::PluginAggregateUdaf in
uni-query.
Implementations§
Source§impl DeclareAggregateProcedure
impl DeclareAggregateProcedure
Sourcepub fn new(
store: Arc<DeclaredPluginStore>,
persistence: Arc<dyn Persistence>,
registry: Arc<PluginRegistry>,
) -> Self
pub fn new( store: Arc<DeclaredPluginStore>, persistence: Arc<dyn Persistence>, registry: Arc<PluginRegistry>, ) -> Self
Construct.
Trait Implementations§
Source§impl Debug for DeclareAggregateProcedure
impl Debug for DeclareAggregateProcedure
Source§impl ProcedurePlugin for DeclareAggregateProcedure
impl ProcedurePlugin for DeclareAggregateProcedure
Source§fn signature(&self) -> &ProcedureSignature
fn signature(&self) -> &ProcedureSignature
Static signature.
Source§fn invoke(
&self,
ctx: ProcedureContext<'_>,
args: &[ColumnarValue],
) -> Result<SendableRecordBatchStream, FnError>
fn invoke( &self, ctx: ProcedureContext<'_>, args: &[ColumnarValue], ) -> Result<SendableRecordBatchStream, FnError>
Invoke the procedure with the given arguments and execution context. Read more
Auto Trait Implementations§
impl !RefUnwindSafe for DeclareAggregateProcedure
impl !UnwindSafe for DeclareAggregateProcedure
impl Freeze for DeclareAggregateProcedure
impl Send for DeclareAggregateProcedure
impl Sync for DeclareAggregateProcedure
impl Unpin for DeclareAggregateProcedure
impl UnsafeUnpin for DeclareAggregateProcedure
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more