Enum StreamingJoinMode 

pub enum StreamingJoinMode {
    Windowed {
        window: StreamingJoinWindow,
    },
    BoundedState {
        limits: StreamingJoinStateLimits,
    },
}

Supported streaming join state classes.

Variants

Windowed

Event-time interval join. Rows are retained until both input watermarks prove they can no longer match a future row within window.

Fields

window: StreamingJoinWindow

Event-time retention policy.

BoundedState

Unbounded SQL equi-join semantics with explicit hard in-memory limits.

Fields

limits: StreamingJoinStateLimits

Hard in-memory state limits.

Trait Implementations

impl Clone for StreamingJoinMode

fn clone(&self) -> StreamingJoinMode

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamingJoinMode

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

Formats the value using the given formatter.

impl Eq for StreamingJoinMode

impl PartialEq for StreamingJoinMode

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for StreamingJoinMode