Struct MemorySink 

pub struct MemorySink { /* private fields */ }

Event sink that collects written batches in memory.

Implementations

impl MemorySink

pub fn new() -> Self

Creates an empty sink.

pub fn schema(&self) -> Option<&Arc<Schema>>

Returns the schema supplied to the most recent write.

pub fn batches(&self) -> &[EventBatch]

Returns collected batches.

pub fn into_batches(self) -> Vec<EventBatch>

Consumes the sink and returns collected batches.

pub fn into_source(self) -> LadduDataResult<MemorySource>

Consumes the sink and builds an in-memory source.

Errors

Returns LadduDataError when the sink contains no batches or incompatible schemas.

pub fn into_batch(self) -> LadduDataResult<EventBatch>

Consumes the sink and concatenates collected batches.

Errors

Returns LadduDataError when no batches were collected or their schemas are incompatible.

pub fn clear(&mut self)

Clears schema, batches, and completion state.

Trait Implementations

impl Clone for MemorySink

fn clone(&self) -> MemorySink

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MemorySink

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

Formats the value using the given formatter.

impl Default for MemorySink

fn default() -> MemorySink

Returns the “default value” for a type.

impl EventSink for MemorySink

fn retains_batches(&self) -> bool

Returns whether written batches remain resident in memory.

fn begin( &mut self, schema: Arc<Schema>, _plan: WritePlan, ) -> LadduDataResult<()>

Begins a write operation.

fn write_batch(&mut self, batch: &EventBatch) -> LadduDataResult<()>

Writes one batch.

fn finish(&mut self) -> LadduDataResult<()>

Finishes and flushes the write operation.