Struct WatermarkSortConfig 

pub struct WatermarkSortConfig {
    pub sort_columns: Vec<OrderColumn>,
    pub max_buffer_size: usize,
}

Configuration for watermark-bounded sort operator.

Fields

sort_columns: Vec<OrderColumn>

Sort columns and directions

max_buffer_size: usize

Maximum buffer size (events)

Implementations

impl WatermarkSortConfig

pub fn with_max_buffer_size(self, max_buffer_size: usize) -> Self

Sets the maximum buffer size.

Trait Implementations

impl Clone for WatermarkSortConfig

fn clone(&self) -> WatermarkSortConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WatermarkSortConfig

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

Formats the value using the given formatter.

impl PartialEq for WatermarkSortConfig

fn eq(&self, other: &WatermarkSortConfig) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for WatermarkSortConfig

impl StructuralPartialEq for WatermarkSortConfig