Type Alias TopNExecutor

pub type TopNExecutor<S, const WITH_TIES: bool> = TopNExecutorWrapper<InnerTopNExecutor<S, WITH_TIES>>;

TopNExecutor works with input with modification, it keeps all the data records/rows that have been seen, and returns topN records overall.

Aliased Type

struct TopNExecutor<S, const WITH_TIES: bool> {
    pub(super) input: Executor,
    pub(super) ctx: Arc<ActorContext>,
    pub(super) inner: InnerTopNExecutor<S, WITH_TIES>,
}

Fields

input: Executor

ctx: Arc<ActorContext>

inner: InnerTopNExecutor<S, WITH_TIES>

Implementations

impl<S: StateStore, const WITH_TIES: bool> TopNExecutor<S, WITH_TIES>

pub fn new( input: Executor, ctx: ActorContextRef, schema: Schema, storage_key: Vec<ColumnOrder>, offset_and_limit: (usize, usize), order_by: Vec<ColumnOrder>, state_table: StateTable<S>, ) -> StreamResult<Self>