Struct InMemoryTableStore 

pub struct InMemoryTableStore { /* private fields */ }

In-memory per-(table, tablet) record-batch store backing InMemoryFragmentExecutor.

Implementations

impl InMemoryTableStore

pub fn new() -> Self

An empty store.

pub fn insert(&self, table: &str, tablet: TabletId, batch: RecordBatch)

Appends one batch to a tablet of a table, registering the table’s schema from the batch on first sight.

pub fn register_schema(&self, table: &str, schema: SchemaRef)

Registers a table schema explicitly (covers tablets with no rows).

pub fn snapshot(&self, table: &str, tablet: TabletId) -> Vec<RecordBatch>

All batches stored for one tablet of a table (empty when none).

pub fn schema(&self, table: &str) -> Option<SchemaRef>

The table’s registered schema, when known.

Trait Implementations

impl Default for InMemoryTableStore

fn default() -> InMemoryTableStore

Returns the “default value” for a type.