pub struct LagLeadOperator { /* private fields */ }Expand description
LAG/LEAD streaming operator.
Implements per-partition LAG and LEAD analytic functions for streaming event processing with checkpoint/restore support.
Implementations§
Source§impl LagLeadOperator
impl LagLeadOperator
Sourcepub fn new(config: LagLeadConfig) -> Self
pub fn new(config: LagLeadConfig) -> Self
Creates a new LAG/LEAD operator from configuration.
Sourcepub fn partition_count(&self) -> usize
pub fn partition_count(&self) -> usize
Returns the number of active partitions.
Sourcepub fn metrics(&self) -> &LagLeadMetrics
pub fn metrics(&self) -> &LagLeadMetrics
Returns a reference to the metrics.
Trait Implementations§
Source§impl Operator for LagLeadOperator
impl Operator for LagLeadOperator
Source§fn process(
&mut self,
event: &Event,
_ctx: &mut OperatorContext<'_>,
) -> OutputVec
fn process( &mut self, event: &Event, _ctx: &mut OperatorContext<'_>, ) -> OutputVec
Process an incoming event
Source§fn on_timer(
&mut self,
_timer: Timer,
_ctx: &mut OperatorContext<'_>,
) -> OutputVec
fn on_timer( &mut self, _timer: Timer, _ctx: &mut OperatorContext<'_>, ) -> OutputVec
Handle timer expiration
Source§fn checkpoint(&self) -> OperatorState
fn checkpoint(&self) -> OperatorState
Checkpoint the operator’s state
Source§fn restore(&mut self, state: OperatorState) -> Result<(), OperatorError>
fn restore(&mut self, state: OperatorState) -> Result<(), OperatorError>
Restore from a checkpoint Read more
Auto Trait Implementations§
impl Freeze for LagLeadOperator
impl !RefUnwindSafe for LagLeadOperator
impl Send for LagLeadOperator
impl Sync for LagLeadOperator
impl Unpin for LagLeadOperator
impl UnsafeUnpin for LagLeadOperator
impl !UnwindSafe for LagLeadOperator
Blanket Implementations§
§impl<T> ArchivePointee for T
impl<T> ArchivePointee for T
§type ArchivedMetadata = ()
type ArchivedMetadata = ()
The archived version of the pointer metadata for this type.
§fn pointer_metadata(
_: &<T as ArchivePointee>::ArchivedMetadata,
) -> <T as Pointee>::Metadata
fn pointer_metadata( _: &<T as ArchivePointee>::ArchivedMetadata, ) -> <T as Pointee>::Metadata
Converts some archived metadata to the pointer metadata for itself.
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<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§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§impl<T> LayoutRaw for T
impl<T> LayoutRaw for T
§fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
Returns the layout of the type.