Struct ProcessorContext 

pub struct ProcessorContext<'ctx, 'd, KOut, VOut> { /* private fields */ }

Handed to Processor::process. forward boxes the record and queues it for each child node (the driver drains the queue).

Two lifetimes: 'ctx is the borrow of the Dispatch reference itself; 'd is the lifetime of the data inside Dispatch (buffers, slices, etc.). Keeping them separate avoids lifetime-invariance issues when constructing a ProcessorContext from a &mut Dispatch<'d> with an independently-scoped outer borrow 'ctx.

Implementations

impl<'ctx, 'd, KOut, VOut> ProcessorContext<'ctx, 'd, KOut, VOut>

where KOut: Any + Send + Clone, VOut: Any + Send + Clone,

pub fn forward(&mut self, record: Record<KOut, VOut>)

Forward a record to all child nodes. The record is cloned per child for fan-out; the last child receives the original by move (so the common single-child case performs zero clones). Mirrors the JVM ProcessorContext.forward(Record), which takes the record by value.

pub fn get_state_store<K2: Send + Sync + 'static, V2: Send + 'static>( &mut self, name: &str, ) -> Option<&mut dyn KeyValueStore<K2, V2>>

Access a connected state store, typed. None if absent or the K/V types don’t match. Fetch it per-record (do not hold across process calls).

pub async fn global_get<GK: Send + Sync + 'static, VG: Send + 'static>( &mut self, store: &str, key: &GK, ) -> Option<VG>

Look up a value in a connected GLOBAL store (fully-replicated, shared across tasks). Returns an owned value — no borrow escapes the shared manager’s lock, so the lookup future need not be held across forward. None on miss / type mismatch. Fetch it per-record (do not hold across process calls).

pub fn get_window_store<K2: Send + Sync + 'static, V2: Send + 'static>( &mut self, name: &str, ) -> Option<&mut dyn WindowStore<K2, V2>>

Access a connected window store, typed. None if absent or the K/V types don’t match. Fetch it per-record (do not hold across process calls).

pub fn get_join_window_store<K2: Send + Sync + 'static, V2: Send + 'static>( &mut self, name: &str, ) -> Option<&mut dyn JoinWindowStore<K2, V2>>

Access a connected join-window store (retainDuplicates), typed. None if absent or the K/V types don’t match. Fetch it per-record (do not hold across process calls).

pub fn get_session_store<K2: Send + Sync + 'static, V2: Send + 'static>( &mut self, name: &str, ) -> Option<&mut dyn SessionStore<K2, V2>>

Access a connected session store, typed. None if absent or the K/V types don’t match. Fetch it per-record (do not hold across process calls).

pub fn get_versioned_store<K2: Send + Sync + 'static, V2: Send + 'static>( &mut self, name: &str, ) -> Option<&mut dyn VersionedKeyValueStore<K2, V2>>

Access a connected versioned store (KIP-889), typed. None if absent or the K/V types don’t match. Fetch it per-record (do not hold across process calls).

pub fn record_context(&self) -> &RecordContext

Metadata of the source record currently being processed.

pub fn store_is_cached(&self, name: &str) -> bool

Whether the named KV state store is record-cached (so this processor should suppress its immediate forward and let the cache flush forward the deduped change). False for absent/non-KV/uncached stores.

pub fn schedule<P>( &mut self, interval: Duration, ty: PunctuationType, punctuator: P, ) -> Cancellable

where P: Punctuator<KOut, VOut>,

Schedule a periodic Punctuator. Callable from init or process. interval must be positive. Returns a Cancellable to stop it.