Trait SqlEventPayload 

pub trait SqlEventPayload {
    // Required method
    fn event_time_batch(&self) -> &RecordBatch;

    // Provided methods
    fn event_time_partition(&self, _row: usize) -> Option<i64> { ... }
    fn event_time_active_partitions(&self) -> Option<Vec<i64>> { ... }
}

Payloads that expose the Arrow batch used to read event-time columns.

Required Methods

fn event_time_batch(&self) -> &RecordBatch

Returns the Arrow batch containing the configured event-time column.

Provided Methods

fn event_time_partition(&self, _row: usize) -> Option<i64>

Partition identity for one row within this source.

The identity is local to a single source. Sources that do not expose partition metadata return None and are treated as one logical partition.

fn event_time_active_partitions(&self) -> Option<Vec<i64>>

Partitions that can still produce rows for this source.

Returning assigned-but-idle partitions lets the watermark generator hold progress until every active partition has produced event-time progress.

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementations on Foreign Types

impl SqlEventPayload for RecordBatch

fn event_time_batch(&self) -> &RecordBatch

Implementors

impl SqlEventPayload for ChangelogBatch

impl SqlEventPayload for CommittableRecordBatch