Struct KeyBy 

pub struct KeyBy { /* private fields */ }

KeyBy operator: copies an existing field into a canonical key field.

Example

use pulse_ops::KeyBy;
let key_by = KeyBy::new("word");

Implementations

impl KeyBy

pub fn new(field: impl Into<String>) -> Self

Trait Implementations

impl Operator for KeyBy

fn on_element<'life0, 'life1, 'async_trait>( &'life0 mut self, ctx: &'life1 mut dyn Context, rec: Record, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn on_watermark<'life0, 'life1, 'async_trait>( &'life0 mut self, _ctx: &'life1 mut dyn Context, _wm: Watermark, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

fn on_timer<'life0, 'life1, 'async_trait>( &'life0 mut self, _ctx: &'life1 mut dyn Context, _when: EventTime, _key: Option<Vec<u8>>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,