Struct datafusion::physical_plan::filter::FilterExec [−][src]
pub struct FilterExec { /* fields omitted */ }
FilterExec evaluates a boolean predicate against all input batches to determine which rows to include in its output batches.
Implementations
impl FilterExec
[src]
impl FilterExec
[src]pub fn try_new(
predicate: Arc<dyn PhysicalExpr>,
input: Arc<dyn ExecutionPlan>
) -> Result<Self>
[src]
predicate: Arc<dyn PhysicalExpr>,
input: Arc<dyn ExecutionPlan>
) -> Result<Self>
Create a FilterExec on an input
pub fn predicate(&self) -> &Arc<dyn PhysicalExpr>
[src]
The expression to filter on. This expression must evaluate to a boolean value.
pub fn input(&self) -> &Arc<dyn ExecutionPlan>
[src]
The input plan
Trait Implementations
impl ExecutionPlan for FilterExec
[src]
impl ExecutionPlan for FilterExec
[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,
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 FilterExec
impl !RefUnwindSafe for FilterExec
impl Send for FilterExec
impl Send for FilterExec
impl Sync for FilterExec
impl Sync for FilterExec
impl Unpin for FilterExec
impl Unpin for FilterExec
impl !UnwindSafe for FilterExec
impl !UnwindSafe for FilterExec