Struct datafusion::datasource::memory::MemTable

pub struct MemTable { /* fields omitted */ }

In-memory table

Implementations

impl MemTable

pub fn new(schema: SchemaRef, partitions: Vec<Vec<RecordBatch>>) -> Result<Self>

Create a new in-memory table from the provided schema and record batches

pub async fn load<'_>(
    t: &'_ dyn TableProvider,
    batch_size: usize
) -> Result<Self>

Create a mem table by reading from another data source

Trait Implementations

impl TableProvider for MemTable

fn schema(&self) -> SchemaRef

Get a reference to the schema for this table

fn scan(
    &self,
    projection: &Option<Vec<usize>>,
    _batch_size: usize
) -> Result<Arc<dyn ExecutionPlan>>

Create an ExecutionPlan that will scan the table.