Struct datafusion::physical_plan::limit::GlobalLimitExec [−][src]
pub struct GlobalLimitExec { /* fields omitted */ }
Limit execution plan
Implementations
impl GlobalLimitExec
[src]
impl GlobalLimitExec
[src]Trait Implementations
impl ExecutionPlan for GlobalLimitExec
[src]
impl ExecutionPlan for GlobalLimitExec
[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 required_child_distribution(&self) -> Distribution
[src]
fn output_partitioning(&self) -> Partitioning
[src]
Get the output partitioning of this plan
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 metrics(&self) -> HashMap<String, SQLMetric>
[src]
Auto Trait Implementations
impl !RefUnwindSafe for GlobalLimitExec
impl !RefUnwindSafe for GlobalLimitExec
impl Send for GlobalLimitExec
impl Send for GlobalLimitExec
impl Sync for GlobalLimitExec
impl Sync for GlobalLimitExec
impl Unpin for GlobalLimitExec
impl Unpin for GlobalLimitExec
impl !UnwindSafe for GlobalLimitExec
impl !UnwindSafe for GlobalLimitExec