Type Alias GroupTopNExecutor

pub type GroupTopNExecutor<K, S, const WITH_TIES: bool> = TopNExecutorWrapper<InnerGroupTopNExecutor<K, S, WITH_TIES>>;

Aliased Type

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

Fields

input: Executor

ctx: Arc<ActorContext>

inner: InnerGroupTopNExecutor<K, S, WITH_TIES>

Implementations

impl<K: HashKey, S: StateStore, const WITH_TIES: bool> GroupTopNExecutor<K, 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>, group_by: Vec<usize>, state_table: StateTable<S>, watermark_epoch: AtomicU64Ref, ) -> StreamResult<Self>