risingwave_stream::executor::source

Module source_executor

Structs§

SourceExecutor
WaitCheckpointTaskBuilder 🔒
WaitCheckpointWorker 🔒
A worker used to do some work after each checkpoint epoch is committed.

Constants§

WAIT_BARRIER_MULTIPLE_TIMES
A constant to multiply when calculating the maximum time to wait for a barrier. This is due to some latencies in network and cost in meta.