Struct datafusion::physical_plan::limit::LocalLimitExec [−][src]
pub struct LocalLimitExec { /* fields omitted */ }
LocalLimitExec applies a limit to a single partition
Implementations
impl LocalLimitExec
[src]
impl LocalLimitExec
[src]Trait Implementations
impl ExecutionPlan for LocalLimitExec
[src]
impl ExecutionPlan for LocalLimitExec
[src]fn as_any(&self) -> &dyn Any
[src]
Return a reference to Any that can be used for downcasting
fn schema(&self) -> SchemaRef
[src]
fn children(&self) -> Vec<Arc<dyn ExecutionPlan>>
[src]
fn output_partitioning(&self) -> Partitioning
[src]
fn with_new_children(
&self,
children: Vec<Arc<dyn ExecutionPlan>>
) -> Result<Arc<dyn ExecutionPlan>>
[src]
&self,
children: 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 LocalLimitExec
impl !RefUnwindSafe for LocalLimitExec
impl Send for LocalLimitExec
impl Send for LocalLimitExec
impl Sync for LocalLimitExec
impl Sync for LocalLimitExec
impl Unpin for LocalLimitExec
impl Unpin for LocalLimitExec
impl !UnwindSafe for LocalLimitExec
impl !UnwindSafe for LocalLimitExec