Enum OrderOperatorConfig 

pub enum OrderOperatorConfig {
    SourceSatisfied,
    TopK(TopKConfig),
    WindowLocalSort(WindowLocalSortConfig),
    WatermarkBoundedSort(WatermarkSortConfig),
    PerGroupTopK(PerGroupTopKConfig),
}

Configuration for a streaming ORDER BY operator.

Each variant corresponds to a different bounded streaming sort strategy.

Variants

SourceSatisfied

Source already satisfies the ordering — no operator needed.

TopK(TopKConfig)

Streaming top-K: ORDER BY … LIMIT N.

Maintains a bounded heap of K entries with retraction-based emission.

WindowLocalSort(WindowLocalSortConfig)

Window-local sort: ORDER BY inside a windowed aggregation.

Buffers per-window output, sorts on window close.

WatermarkBoundedSort(WatermarkSortConfig)

Watermark-bounded sort: ORDER BY event_time on out-of-order input.

Buffers events between watermarks, emits sorted on watermark advance.

PerGroupTopK(PerGroupTopKConfig)

Per-group top-K: ROW_NUMBER() OVER (PARTITION BY … ORDER BY …) WHERE rn <= N.

Independent top-K heaps per partition key.

Implementations

impl OrderOperatorConfig

pub fn from_analysis(analysis: &OrderAnalysis) -> Result<Option<Self>, String>

Creates an operator configuration from an ORDER BY analysis.

Maps the classified pattern to the appropriate operator config. Returns None for OrderPattern::None (no ORDER BY).

Errors

Returns error string for OrderPattern::Unbounded.

pub fn watermark_bounded(sort_columns: Vec<OrderColumn>) -> Self

Creates a watermark-bounded sort config for event time ordering.

Trait Implementations

impl Clone for OrderOperatorConfig

fn clone(&self) -> OrderOperatorConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OrderOperatorConfig

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

Formats the value using the given formatter.

impl PartialEq for OrderOperatorConfig

fn eq(&self, other: &OrderOperatorConfig) -> 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 OrderOperatorConfig

impl StructuralPartialEq for OrderOperatorConfig