Struct CommittableRecordBatch 

pub struct CommittableRecordBatch { /* private fields */ }

Append-only SQL batch plus source metadata and a deferred commit handle.

Implementations

impl CommittableRecordBatch

pub fn new( batch: RecordBatch, source_position: Option<SqlSourcePosition>, schema_revision: u64, commit: SourceCommit, ) -> Self

Creates an append-only SQL batch with source metadata and a commit hook.

pub fn plain(batch: RecordBatch) -> Self

Wraps an ordinary Arrow batch with no source position.

pub fn batch(&self) -> &RecordBatch

Returns the Arrow payload batch.

pub fn envelope(&self) -> &BatchEnvelope<Option<SqlSourcePosition>>

Returns the connector-side envelope.

pub fn source_position(&self) -> Option<&SqlSourcePosition>

Returns the optional source position.

pub fn schema_revision(&self) -> u64

Returns the schema revision attached by the source adapter.

pub fn commit_handle(&self) -> &SourceCommit

Returns the deferred source commit handle.

pub fn commit(&self) -> StreamResult<()>

Commits the source position after a sink write has succeeded.

Trait Implementations

impl Clone for CommittableRecordBatch

fn clone(&self) -> CommittableRecordBatch

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CommittableRecordBatch

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

Formats the value using the given formatter.

impl SqlEventPayload for CommittableRecordBatch

fn event_time_batch(&self) -> &RecordBatch

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

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

Partition identity for one row within this source.

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

Partitions that can still produce rows for this source.