Struct PartitionedTopKOperator 

pub struct PartitionedTopKOperator { /* private fields */ }

Partitioned top-K operator.

Maintains independent top-K heaps per partition key. Supports the ROW_NUMBER() OVER (PARTITION BY ... ORDER BY ...) WHERE rn <= N pattern.

Implementations

impl PartitionedTopKOperator

pub fn new( operator_id: String, k: usize, partition_columns: Vec<PartitionColumn>, sort_columns: Vec<TopKSortColumn>, emit_strategy: TopKEmitStrategy, max_partitions: usize, ) -> Self

Creates a new partitioned top-K operator.

pub fn partition_count(&self) -> usize

Returns the number of active partitions.

pub fn total_entries(&self) -> usize

Returns the total number of entries across all partitions.

pub fn partition_size(&self, partition_key: &[u8]) -> usize

Returns the number of entries in a specific partition.

pub fn pending_changes_count(&self) -> usize

Returns the number of pending changelog records.

Trait Implementations

impl Operator for PartitionedTopKOperator

fn process( &mut self, event: &Event, _ctx: &mut OperatorContext<'_>, ) -> OutputVec

Process an incoming event

fn on_timer( &mut self, _timer: Timer, _ctx: &mut OperatorContext<'_>, ) -> OutputVec

Handle timer expiration

fn checkpoint(&self) -> OperatorState

Checkpoint the operator’s state

fn restore(&mut self, state: OperatorState) -> Result<(), OperatorError>

Restore from a checkpoint