Trait TopNExecutorBase

pub trait TopNExecutorBase: Send + 'static {
    type State: StateStore;

    // Required methods
    fn apply_chunk(
        &mut self,
        chunk: StreamChunk,
    ) -> impl Future<Output = StreamExecutorResult<Option<StreamChunk>>> + Send;
    fn flush_data(
        &mut self,
        epoch: EpochPair,
    ) -> impl Future<Output = StreamExecutorResult<StateTablePostCommit<'_, Self::State>>> + Send;
    fn try_flush_data(
        &mut self,
    ) -> impl Future<Output = StreamExecutorResult<()>> + Send;
    fn init(
        &mut self,
        epoch: EpochPair,
    ) -> impl Future<Output = StreamExecutorResult<()>> + Send;
    fn handle_watermark(
        &mut self,
        watermark: Watermark,
    ) -> impl Future<Output = Option<Watermark>> + Send;

    // Provided methods
    fn clear_cache(&mut self) { ... }
    fn evict(&mut self) { ... }
}

Required Associated Types

type State: StateStore

Required Methods

fn apply_chunk( &mut self, chunk: StreamChunk, ) -> impl Future<Output = StreamExecutorResult<Option<StreamChunk>>> + Send

Apply the chunk to the dirty state and get the diffs. TODO(rc): There can be a 2 times amplification in terms of the chunk size, so we may need to allow apply_chunk return a stream of chunks. Motivation is not quite strong though.

fn flush_data( &mut self, epoch: EpochPair, ) -> impl Future<Output = StreamExecutorResult<StateTablePostCommit<'_, Self::State>>> + Send

Flush the buffered chunk to the storage backend.

fn try_flush_data( &mut self, ) -> impl Future<Output = StreamExecutorResult<()>> + Send

Flush the buffered chunk to the storage backend.

fn init( &mut self, epoch: EpochPair, ) -> impl Future<Output = StreamExecutorResult<()>> + Send

fn handle_watermark( &mut self, watermark: Watermark, ) -> impl Future<Output = Option<Watermark>> + Send

Handle incoming watermarks

Provided Methods

fn clear_cache(&mut self)

fn evict(&mut self)

Object Safety

This trait is not object safe.

Implementors

impl<K: HashKey, S: StateStore, const WITH_TIES: bool> TopNExecutorBase for InnerGroupTopNExecutor<K, S, WITH_TIES>

where TopNCache<WITH_TIES>: TopNCacheTrait,

type State = S

impl<K: HashKey, S: StateStore, const WITH_TIES: bool> TopNExecutorBase for InnerAppendOnlyGroupTopNExecutor<K, S, WITH_TIES>

where TopNCache<WITH_TIES>: AppendOnlyTopNCacheTrait,

type State = S

impl<S: StateStore, const WITH_TIES: bool> TopNExecutorBase for InnerAppendOnlyTopNExecutor<S, WITH_TIES>

where TopNCache<WITH_TIES>: AppendOnlyTopNCacheTrait,

type State = S

impl<S: StateStore, const WITH_TIES: bool> TopNExecutorBase for InnerTopNExecutor<S, WITH_TIES>

where TopNCache<WITH_TIES>: TopNCacheTrait,

type State = S