Struct MemorySource 

pub struct MemorySource { /* private fields */ }

Replayable in-memory event source backed by one or more batches.

Implementations

impl MemorySource

pub fn new(batch: EventBatch) -> Self

Creates a source containing one batch.

pub fn from_batches(batches: Vec<EventBatch>) -> LadduDataResult<Self>

Validates and creates a source from nonempty schema-compatible batches.

Errors

Returns LadduDataError when batches is empty or contains incompatible schemas.

pub fn from_events<I>(schema: Arc<Schema>, events: I) -> LadduDataResult<Self>

where I: IntoIterator<Item = OwnedEvent>,

Collects owned events into an in-memory source.

Errors

Returns LadduDataError when an event does not match schema or weighted and unweighted events are mixed.

pub fn schema_arc(&self) -> &Arc<Schema>

Returns the shared schema.

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

Returns the backing batches.

pub fn into_batches(self) -> Arc<[EventBatch]>

Consumes the source and returns its shared batches.

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

Consumes and concatenates all batches.

Errors

Returns LadduDataError when no batches are present or their schemas are incompatible.

Trait Implementations

impl Clone for MemorySource

fn clone(&self) -> MemorySource

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MemorySource

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

Formats the value using the given formatter.

impl EventSource for MemorySource

fn schema(&self) -> LadduDataResult<Arc<Schema>>

Returns the source schema.

fn capabilities(&self) -> SourceCapabilities

Returns optional source capabilities.

fn num_events(&self) -> LadduDataResult<Option<u64>>

Returns the exact event count when cheaply available.

fn weighted_total(&self) -> LadduDataResult<Option<f64>>

Returns the exact sum of event weights when cheaply available.

fn batches( &self, plan: ReadPlan, ) -> LadduDataResult<Box<dyn Iterator<Item = LadduDataResult<EventBatch>> + Send>>

Opens a batch iterator using plan.

impl FragmentedSource for MemorySource

type Key = MemoryFragmentKey

Source-specific fragment key.

fn fragments(&self) -> LadduDataResult<Vec<DataFragment<Self::Key>>>

Lists all fragments in global row order.

fn read_fragment_range( &self, key: &Self::Key, local_start: usize, local_len: usize, chunk_size: Option<usize>, ) -> LadduDataResult<Box<dyn Iterator<Item = LadduDataResult<EventBatch>> + Send>>

Reads a contiguous range within one fragment.