Struct datafusion::physical_plan::memory::MemoryExec [−][src]
pub struct MemoryExec { /* fields omitted */ }
Execution plan for reading in-memory batches of data
Implementations
impl MemoryExec
[src]
impl MemoryExec
[src]Trait Implementations
impl ExecutionPlan for MemoryExec
[src]
impl ExecutionPlan for MemoryExec
[src]fn as_any(&self) -> &dyn Any
[src]
Return a reference to Any that can be used for downcasting
fn schema(&self) -> SchemaRef
[src]
Get the schema for this execution plan
fn children(&self) -> Vec<Arc<dyn ExecutionPlan>>
[src]
fn output_partitioning(&self) -> Partitioning
[src]
Get the output partitioning of this plan
fn with_new_children(
&self,
_: Vec<Arc<dyn ExecutionPlan>>
) -> Result<Arc<dyn ExecutionPlan>>
[src]
&self,
_: Vec<Arc<dyn ExecutionPlan>>
) -> Result<Arc<dyn ExecutionPlan>>
fn execute<'life0, 'async_trait>(
&'life0 self,
partition: usize
) -> Pin<Box<dyn Future<Output = Result<SendableRecordBatchStream>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
[src]
&'life0 self,
partition: usize
) -> Pin<Box<dyn Future<Output = Result<SendableRecordBatchStream>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn required_child_distribution(&self) -> Distribution
[src]
fn metrics(&self) -> HashMap<String, SQLMetric>
[src]
Auto Trait Implementations
impl !RefUnwindSafe for MemoryExec
impl !RefUnwindSafe for MemoryExec
impl Send for MemoryExec
impl Send for MemoryExec
impl Sync for MemoryExec
impl Sync for MemoryExec
impl Unpin for MemoryExec
impl Unpin for MemoryExec
impl !UnwindSafe for MemoryExec
impl !UnwindSafe for MemoryExec