Trait Operator 

pub trait Operator: Send {
    // Required methods
    fn process(
        &mut self,
        event: &Event,
        ctx: &mut OperatorContext<'_>,
    ) -> OutputVec;
    fn on_timer(
        &mut self,
        timer: Timer,
        ctx: &mut OperatorContext<'_>,
    ) -> OutputVec;
    fn checkpoint(&self) -> OperatorState;
    fn restore(&mut self, state: OperatorState) -> Result<(), OperatorError>;
}

Trait implemented by all streaming operators

Required Methods

fn process(&mut self, event: &Event, ctx: &mut OperatorContext<'_>) -> OutputVec

Process an incoming event

fn on_timer(&mut self, timer: Timer, ctx: &mut OperatorContext<'_>) -> OutputVec

Handle timer expiration

fn checkpoint(&self) -> OperatorState

Checkpoint the operator’s state

fn restore(&mut self, state: OperatorState) -> Result<(), OperatorError>

Restore from a checkpoint

Errors

Returns OperatorError::StateAccessFailed if the state cannot be accessed Returns OperatorError::SerializationFailed if the state cannot be deserialized

Implementors

impl Operator for AsofJoinOperator

impl Operator for LagLeadOperator

impl Operator for PartitionedTopKOperator

impl Operator for StreamJoinOperator

impl Operator for TemporalJoinOperator

impl Operator for StreamingTopKOperator

impl Operator for WatermarkBoundedSortOperator

impl Operator for WindowLocalSortOperator

impl<A: Aggregator> Operator for SessionWindowOperator<A>

where A::Acc: 'static + Archive + for<'a> RkyvSerialize<HighSerializer<AlignedVec, ArenaHandle<'a>, Error>>, <A::Acc as Archive>::Archived: for<'a> CheckBytes<HighValidator<'a, Error>> + RkyvDeserialize<A::Acc, HighDeserializer<Error>>,

impl<A: Aggregator> Operator for SlidingWindowOperator<A>

where A::Acc: 'static + Archive + for<'a> RkyvSerialize<HighSerializer<AlignedVec, ArenaHandle<'a>, Error>>, <A::Acc as Archive>::Archived: for<'a> CheckBytes<HighValidator<'a, Error>> + RkyvDeserialize<A::Acc, HighDeserializer<Error>>,

impl<A: Aggregator> Operator for TumblingWindowOperator<A>

where A::Acc: 'static + Archive + for<'a> RkyvSerialize<HighSerializer<AlignedVec, ArenaHandle<'a>, Error>>, <A::Acc as Archive>::Archived: for<'a> CheckBytes<HighValidator<'a, Error>> + RkyvDeserialize<A::Acc, HighDeserializer<Error>>,