risingwave_stream::executor::source

Module source_executor

Source

Structs§

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

Enums§

ApplyMutationAfterBarrier 🔒

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.

Functions§

extract_pg_cdc_lsn_from_offset 🔒
This function parses the offset JSON and extracts the LSN value from the sourceOffset.lsn field. Returns Some(lsn) if the LSN is found and can be parsed as u64, None otherwise.
extract_split_offset 🔒
Extract offset value from CDC split