ic4y commented on a change in pull request #1309:
URL: https://github.com/apache/arrow-datafusion/pull/1309#discussion_r753695179
##########
File path: datafusion/src/logical_plan/plan.rs
##########
@@ -57,6 +57,47 @@ pub enum JoinConstraint {
Using,
}
+/// Evaluates an arbitrary list of expressions (essentially a
+/// SELECT with an expression list) on its input.
+#[derive(Clone)]
+pub struct ProjectionPlan {
+ /// The list of expressions
+ pub expr: Vec<Expr>,
+ /// The incoming logical plan
+ pub input: Arc<LogicalPlan>,
+ /// The schema description of the output
+ pub schema: DFSchemaRef,
+ /// Projection output relation alias
+ pub alias: Option<String>,
+}
+
+/// Filters rows from its input that do not match an
+/// expression (essentially a WHERE clause with a predicate
+/// expression).
+///
+/// Semantically, `<predicate>` is evaluated for each row of the input;
+/// If the value of `<predicate>` is true, the input row is passed to
+/// the output. If the value of `<predicate>` is false, the row is
+/// discarded.
+#[derive(Clone)]
+pub struct FilterPlan {
+ /// The predicate expression, which must have Boolean type.
+ pub predicate: Expr,
+ /// The incoming logical plan
+ pub input: Arc<LogicalPlan>,
+}
+
+/// Window its input based on a set of window spec and window function (e.g.
SUM or RANK)
+#[derive(Clone)]
+pub struct WindowPlan {
Review comment:
OK, thanks @alamb I will modify according to your suggestion.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscr...@arrow.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
