Struct datafusion::datasource::memory::MemTable [−][src]
pub struct MemTable { /* fields omitted */ }
In-memory table
Implementations
impl MemTable
[src]
impl MemTable
[src]pub fn try_new(
schema: SchemaRef,
partitions: Vec<Vec<RecordBatch>>
) -> Result<Self>
[src]
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: Arc<dyn TableProvider>,
batch_size: usize,
output_partitions: Option<usize>
) -> Result<Self>
[src]
t: Arc<dyn TableProvider>,
batch_size: usize,
output_partitions: Option<usize>
) -> Result<Self>
Create a mem table by reading from another data source
Trait Implementations
impl TableProvider for MemTable
[src]
impl TableProvider for MemTable
[src]fn as_any(&self) -> &dyn Any
[src]
fn schema(&self) -> SchemaRef
[src]
fn scan(
&self,
projection: &Option<Vec<usize>>,
_batch_size: usize,
_filters: &[Expr],
_limit: Option<usize>
) -> Result<Arc<dyn ExecutionPlan>>
[src]
&self,
projection: &Option<Vec<usize>>,
_batch_size: usize,
_filters: &[Expr],
_limit: Option<usize>
) -> Result<Arc<dyn ExecutionPlan>>
fn statistics(&self) -> Statistics
[src]
fn supports_filter_pushdown(
&self,
_filter: &Expr
) -> Result<TableProviderFilterPushDown>
[src]
&self,
_filter: &Expr
) -> Result<TableProviderFilterPushDown>
Auto Trait Implementations
impl !RefUnwindSafe for MemTable
impl !RefUnwindSafe for MemTable
impl !UnwindSafe for MemTable
impl !UnwindSafe for MemTable