Struct rlink::functions::watermark::time_periodic_watermarks::TimePeriodicWatermarks [−][src]
pub struct TimePeriodicWatermarks { /* fields omitted */ }
Expand description
Determine whether to generate watermark based on the rate of processing time and event time
check condition: event_timestamp(n) - event_timestamp(m) > event_period, (n > m) trigger condition: process_timestamp(n) - process_timestamp(m) < process_period
Implementations
Trait Implementations
Auto Trait Implementations
impl !RefUnwindSafe for TimePeriodicWatermarks
impl !Send for TimePeriodicWatermarks
impl !Sync for TimePeriodicWatermarks
impl Unpin for TimePeriodicWatermarks
impl !UnwindSafe for TimePeriodicWatermarks
Blanket Implementations
Mutably borrows from an owned value. Read more
Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
type Output = T
type Output = T
Should always be Self