-
Notifications
You must be signed in to change notification settings - Fork 2k
Labels
bugSomething isn't workingSomething isn't working
Description
Describe the bug
see releated code
datafusion/datafusion/proto/proto/datafusion.proto
Lines 1031 to 1037 in b3976d6
| message FilterExecNode { | |
| PhysicalPlanNode input = 1; | |
| PhysicalExprNode expr = 2; | |
| uint32 default_filter_selectivity = 3; | |
| repeated uint32 projection = 9; | |
| uint32 batch_size = 10; | |
| } |
and
datafusion/datafusion/physical-plan/src/filter.rs
Lines 79 to 96 in b3976d6
| pub struct FilterExec { | |
| /// The expression to filter on. This expression must evaluate to a boolean value. | |
| predicate: Arc<dyn PhysicalExpr>, | |
| /// The input plan | |
| input: Arc<dyn ExecutionPlan>, | |
| /// Execution metrics | |
| metrics: ExecutionPlanMetricsSet, | |
| /// Selectivity for statistics. 0 = no rows, 100 = all rows | |
| default_selectivity: u8, | |
| /// Properties equivalence properties, partitioning, etc. | |
| cache: Arc<PlanProperties>, | |
| /// The projection indices of the columns in the output schema of join | |
| projection: Option<ProjectionRef>, | |
| /// Target batch size for output batches | |
| batch_size: usize, | |
| /// Number of rows to fetch | |
| fetch: Option<usize>, | |
| } |
To Reproduce
No response
Expected behavior
No response
Additional context
No response
Reactions are currently unavailable
Metadata
Metadata
Assignees
Labels
bugSomething isn't workingSomething isn't working