Enum SortBehaviour 

pub enum SortBehaviour {
    None,
    RequestKeys,
    Ordered,
}

Controls how a parallel reader surfaces and orders the per-table sequence keys carried on each record batch by the ordered parallel writers.

Variants

None

Do not surface sequence keys. Every item’s key is None and tables arrive in the order the streams produce them, at no ordering cost.

RequestKeys

Surface each table’s sequence key without reordering. Tables arrive in stream-production order. The caller sorts on the keys to recover global write order across streams.

Ordered

Emit tables in global write order across streams. The reader pulls the streams in the writer’s round-robin rotation, so each table surfaces in ascending sequence on the streaming interface and in read_all_tables. A lagging stream holds back the tables behind it, the bound on per-stream buffering inherent to any ordered merge.

Trait Implementations

impl Clone for SortBehaviour

fn clone(&self) -> SortBehaviour

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for SortBehaviour

impl Debug for SortBehaviour

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

Formats the value using the given formatter.

impl Eq for SortBehaviour

impl PartialEq for SortBehaviour

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for SortBehaviour