Struct FlowScanDecision 

struct FlowScanDecision {
    is_sink_scan: bool,
    snapshot_on_scan: bool,
    memtable_min_sequence: Option<u64>,
    memtable_max_sequence: Option<u64>,
    skip_sst_files: bool,
    exact_sequence_range: bool,
}

Fields

is_sink_scan: bool

Whether this region is the flow sink-table scan. Sink scans intentionally bypass incremental and snapshot-binding semantics.

snapshot_on_scan: bool

Whether this scan should bind a memtable upper bound when opening the scan. This is only the initial intent; if a cached bound already exists in query_ctx, we reuse that cached bound instead and clear this flag.

memtable_min_sequence: Option<u64>

Optional lower exclusive memtable sequence bound for incremental reads. When set, only rows with sequence strictly greater than this bound are read from memtables.

memtable_max_sequence: Option<u64>

Optional cached per-region snapshot already bound in query_ctx. When present, this becomes the effective memtable upper bound and suppresses binding a new snapshot on scan open.

skip_sst_files: bool

Whether to skip SST files for memtable-only incremental source scans.

exact_sequence_range: bool

Whether this source scan must enforce the exact sequence range.

Implementations

impl FlowScanDecision

fn plain_scan() -> Self

Trait Implementations

impl Clone for FlowScanDecision

fn clone(&self) -> FlowScanDecision

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for FlowScanDecision

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl PartialEq for FlowScanDecision

fn eq(&self, other: &FlowScanDecision) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for FlowScanDecision

impl StructuralPartialEq for FlowScanDecision