Struct StreamingConfigV2 

pub struct StreamingConfigV2 {
    pub base: StreamingConfig,
    pub backpressure: Option<BackpressureConfig>,
    pub watermark: Option<WatermarkConfig>,
}

Extended streaming configuration combining the base config with v2 features.

Fields

base: StreamingConfig

Base streaming configuration.

backpressure: Option<BackpressureConfig>

Optional backpressure configuration.

watermark: Option<WatermarkConfig>

Optional watermark configuration.

Implementations

impl StreamingConfigV2

pub fn new(base: StreamingConfig) -> Self

Create a new StreamingConfigV2 wrapping the given base config.

pub fn with_backpressure(self, config: BackpressureConfig) -> Self

Attach a backpressure configuration.

pub fn with_watermark(self, config: WatermarkConfig) -> Self

Attach a watermark configuration.

pub fn should_apply_backpressure(&self, current_buffered: usize) -> bool

Returns true when backpressure should be applied for the given buffer level.

pub fn is_late_event(&self, event_time_ms: u64, watermark_ms: u64) -> bool

Returns true when the given event timestamp is late relative to the watermark.

Trait Implementations

impl Clone for StreamingConfigV2

fn clone(&self) -> StreamingConfigV2

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for StreamingConfigV2

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for StreamingConfigV2

fn default() -> Self

Returns the “default value” for a type.