Enum Attribute 

pub enum Attribute {
    Name(Arc<str>),
    InputBuffer {
        initial: usize,
        max: usize,
    },
    Dispatcher(Arc<str>),
    BatchSize(usize),
    Parallelism(usize),
    Fusion(Fusion),
    MetricsLevel(MetricsLevel),
    KernelBackend(KernelBackend),
}

A single validated stream/stage planner attribute.

Variants

Name(Arc<str>)

Human-readable stage/stream name (used in diagnostics).

InputBuffer

Requested input-buffer sizing hint (initial ≤ max).

Fields

initial: usize

max: usize

Dispatcher(Arc<str>)

Dispatcher name hint for where the stage’s work should run.

BatchSize(usize)

Preferred batch size for batch-producing or batch-coalescing stages.

Parallelism(usize)

Per-node concurrency limit where semantics allow parallel work.

Fusion(Fusion)

Fusion constraint/preference.

MetricsLevel(MetricsLevel)

Requested metrics detail.

KernelBackend(KernelBackend)

Kernel backend preference.

Trait Implementations

impl Clone for Attribute

fn clone(&self) -> Attribute

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Attribute

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

Formats the value using the given formatter.

impl Eq for Attribute

impl PartialEq for Attribute

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for Attribute