Struct OutputCollector 

pub struct OutputCollector { /* private fields */ }

Accumulates batches and log messages for one streaming iteration.

Implementations

impl OutputCollector

pub fn schema(&self) -> SchemaRef

The stream’s output schema.

pub fn emit(&mut self, batch: RecordBatch) -> Result<()>

Emit a data batch. Schema must match self.schema() exactly.

pub fn emit_with_metadata( &mut self, batch: RecordBatch, metadata: Metadata, ) -> Result<()>

Emit a data batch with per-batch custom metadata (e.g. VGI’s vgi_batch_index / vgi_partition_values#b64 ordering tags).

pub fn finish(&mut self)

Mark the stream as finished (producer only).

pub fn finished(&self) -> bool

pub fn client_log(&mut self, level: LogLevel, message: impl Into<String>)

Append a client-directed log message.

pub fn client_log_with(&mut self, msg: LogMessage)

Append a client-directed log message with extras.

pub fn is_producer(&self) -> bool