Skip to content

FilterExec's fetch not impl the ser/de in protobuf #20737

@haohuaijin

Description

@haohuaijin

Describe the bug

see releated code

message FilterExecNode {
PhysicalPlanNode input = 1;
PhysicalExprNode expr = 2;
uint32 default_filter_selectivity = 3;
repeated uint32 projection = 9;
uint32 batch_size = 10;
}

and
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

Metadata

Metadata

Assignees

Labels

bugSomething isn't working

Type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions