Tpt commented on code in PR #18993:
URL: https://github.com/apache/datafusion/pull/18993#discussion_r2573941082
##########
datafusion/physical-plan/src/work_table.rs:
##########
@@ -103,25 +103,35 @@ pub struct WorkTableExec {
name: String,
/// The schema of the stream
schema: SchemaRef,
+ /// Projection to apply to build the output stream from the recursion state
+ projection: Option<Vec<usize>>,
/// The work table
work_table: Arc<WorkTable>,
/// Execution metrics
metrics: ExecutionPlanMetricsSet,
/// Cache holding plan properties like equivalences, output partitioning
etc.
Review Comment:
Indeed, I have moved back the field name to `cache` to stay consistent with
a lot of other operator implementations:
69464d2b73919d79fdf8176dbfa7645ca66e5e2f
##########
datafusion/physical-plan/src/work_table.rs:
##########
Review Comment:
Done! 304d40c2484e8873abbfd33be80a957be1e1257b
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
