waynexia commented on a change in pull request #8662:
URL: https://github.com/apache/arrow/pull/8662#discussion_r523620024
##########
File path: rust/datafusion/src/physical_plan/projection.rs
##########
@@ -114,14 +117,33 @@ impl ExecutionPlan for ProjectionExec {
}
async fn execute(&self, partition: usize) ->
Result<SendableRecordBatchStream> {
+ let input = if
self.input.as_any().downcast_ref::<EmptyExec>().is_some() {
Review comment:
@jhorstmann thanks for your suggestion!
Hi @alamb @jorgecarleitao, what do you think of this? I'm OK with both. But
in my opinion, I prefer the first one because I think it's enough for this
situation.
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]