Module fs_fetch_executor

risingwave_stream::executor::source

Module fs_fetch_executor 

Source

Structs§

FsFetchExecutor
ReplaceReaderArgs 🔒
SetReadingFileOnPoll 🔒
A stream wrapper that sets reading_file before polling the underlying stream for the first time.

Constants§

MAX_RETRIES_PER_SPLIT 🔒
RETRY_BASE_BACKOFF 🔒
SPLIT_BATCH_SIZE 🔒

Type Aliases§

SplitBatch 🔒