pub struct DeclareProcedureProcedure { /* private fields */ }Expand description
Record-and-persist implementation for a declare* kind.
Stores the declaration through Persistence. When a
host-supplied procedure-body synthesizer is attached,
the declaration also installs an executable plugin via
crate::procedures::install_synthesized_procedure
(M11 A.3).
Implementations§
Source§impl DeclareProcedureProcedure
impl DeclareProcedureProcedure
Sourcepub fn new(
store: Arc<DeclaredPluginStore>,
persistence: Arc<dyn Persistence>,
) -> Self
pub fn new( store: Arc<DeclaredPluginStore>, persistence: Arc<dyn Persistence>, ) -> Self
Construct without a synthesizer (record-only).
Sourcepub fn new_with_synthesis(
store: Arc<DeclaredPluginStore>,
persistence: Arc<dyn Persistence>,
registry: Arc<PluginRegistry>,
synthesizer: Arc<dyn ProcedureBodySynthesizer>,
) -> Self
pub fn new_with_synthesis( store: Arc<DeclaredPluginStore>, persistence: Arc<dyn Persistence>, registry: Arc<PluginRegistry>, synthesizer: Arc<dyn ProcedureBodySynthesizer>, ) -> Self
Construct with a host-supplied synthesizer so declarations install executable plugins at declare time (M11 A.3).
Trait Implementations§
Source§impl Debug for DeclareProcedureProcedure
impl Debug for DeclareProcedureProcedure
Source§impl ProcedurePlugin for DeclareProcedureProcedure
impl ProcedurePlugin for DeclareProcedureProcedure
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 DeclareProcedureProcedure
impl !UnwindSafe for DeclareProcedureProcedure
impl Freeze for DeclareProcedureProcedure
impl Send for DeclareProcedureProcedure
impl Sync for DeclareProcedureProcedure
impl Unpin for DeclareProcedureProcedure
impl UnsafeUnpin for DeclareProcedureProcedure
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