Struct RecordBatchSink 

pub struct RecordBatchSink { /* private fields */ }

Buffers tracing events and produces Arrow RecordBatches.

Implements TraceEventSink for tracing events (spans, log events).

This type can be cloned to get a handle for flushing from outside the telemetry system. Clone it before registering with telemetry if you need to call flush() later.

Produces three tables:

• spans: Information about span creation (NewSpan events)
• span_events: Enter/exit/close events for spans
• events: Tracing events (e.g., tracing::info!())

For entity lifecycle events (actors, meshes), see EntityDispatcher.

Implementations

impl RecordBatchSink

pub fn new(batch_size: usize, flush_callback: FlushCallback) -> Self

Create a new RecordBatchSink with the specified batch size and flush callback.

The callback receives (table_name, record_batch) when a batch is ready. The callback should handle empty batches by creating the table with the schema but not appending the empty data.

Arguments

• batch_size - Number of rows to buffer before flushing each table
• flush_callback - Called with (table_name, record_batch) when a batch is ready

pub fn flush(&self) -> Result<()>

Flush all buffers, emitting batches for all tables.

This always emits batches for all three tables (spans, span_events, events), even if they are empty. The callback is expected to handle empty batches by creating the table with the correct schema but not appending empty data.

pub fn new_printing(batch_size: usize) -> Self

Create a new RecordBatchSink that prints batches to stdout.

Trait Implementations

impl Clone for RecordBatchSink

fn clone(&self) -> RecordBatchSink

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl TraceEventSink for RecordBatchSink

fn consume(&mut self, event: &TraceEvent) -> Result<(), Error>

Consume a single event. Called on background thread.

fn flush(&mut self) -> Result<(), Error>

Flush any buffered events to the backend. Called periodically and on shutdown.

fn name(&self) -> &str

Optional: return name for debugging/logging

fn target_filter(&self) -> Option<&Targets>

Optional target/level filter for this sink.