Enum SqlEvent 

pub enum SqlEvent<T> {
    Data(T),
    Watermark(Watermark),
    Barrier(SqlBarrier),
}

In-band SQL stream envelope for data and control records.

Variants

Data(T)

User data payload.

Watermark(Watermark)

Event-time progress marker.

Barrier(SqlBarrier)

Checkpoint or alignment marker.

Implementations

impl<T> SqlEvent<T>

pub fn map_data_result<U, F>(self, f: F) -> StreamResult<SqlEvent<U>>

where F: FnOnce(T) -> StreamResult<U>,

Maps only the data branch and passes watermarks and barriers through.

pub const fn as_watermark(&self) -> Option<Watermark>

Returns the contained watermark when this event is a watermark.

Trait Implementations

impl<T: Clone> Clone for SqlEvent<T>

fn clone(&self) -> SqlEvent<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for SqlEvent<T>

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

Formats the value using the given formatter.

impl<T: Eq> Eq for SqlEvent<T>

impl<T: PartialEq> PartialEq for SqlEvent<T>

fn eq(&self, other: &SqlEvent<T>) -> bool

Equality operator ==.

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

Inequality operator !=.

impl<T: PartialEq> StructuralPartialEq for SqlEvent<T>