Struct datafusion::physical_plan::sort::SortExec [−][src]
pub struct SortExec { /* fields omitted */ }
Sort execution plan
Implementations
impl SortExec
[src]
impl SortExec
[src]pub fn try_new(
expr: Vec<PhysicalSortExpr>,
input: Arc<dyn ExecutionPlan>
) -> Result<Self>
[src]
expr: Vec<PhysicalSortExpr>,
input: Arc<dyn ExecutionPlan>
) -> Result<Self>
Create a new sort execution plan
pub fn input(&self) -> &Arc<dyn ExecutionPlan>
[src]
Input schema
pub fn expr(&self) -> &[PhysicalSortExpr]
[src]
Sort expressions
Trait Implementations
impl ExecutionPlan for SortExec
[src]
impl ExecutionPlan for SortExec
[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]
Get the output partitioning of this plan
fn required_child_distribution(&self) -> Distribution
[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 metrics(&self) -> HashMap<String, SQLMetric>
[src]
Auto Trait Implementations
impl !RefUnwindSafe for SortExec
impl !RefUnwindSafe for SortExec
impl !UnwindSafe for SortExec
impl !UnwindSafe for SortExec