You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@arrow.apache.org by ks...@apache.org on 2019/03/01 07:14:28 UTC
[arrow] branch master updated: ARROW-4721: [Rust] [DataFusion]
Propagate schema in filter
This is an automated email from the ASF dual-hosted git repository.
kszucs pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/arrow.git
The following commit(s) were added to refs/heads/master by this push:
new 9144342 ARROW-4721: [Rust] [DataFusion] Propagate schema in filter
9144342 is described below
commit 9144342639296daebb41a44dea8a15ffe5dba88f
Author: Nicolas Trinquier <ns...@protonmail.ch>
AuthorDate: Fri Mar 1 08:14:02 2019 +0100
ARROW-4721: [Rust] [DataFusion] Propagate schema in filter
Author: Nicolas Trinquier <ns...@protonmail.ch>
Closes #3784 from ntrinquier/ARROW-4721 and squashes the following commits:
4ba45041 <Nicolas Trinquier> Propagate schema in filter
---
rust/datafusion/src/execution/filter.rs | 6 ++----
1 file changed, 2 insertions(+), 4 deletions(-)
diff --git a/rust/datafusion/src/execution/filter.rs b/rust/datafusion/src/execution/filter.rs
index 8e70670..c4d1cec 100644
--- a/rust/datafusion/src/execution/filter.rs
+++ b/rust/datafusion/src/execution/filter.rs
@@ -70,10 +70,8 @@ impl Relation for FilterRelation {
})
.collect();
- let filtered_batch: RecordBatch = RecordBatch::new(
- Arc::new(Schema::empty()),
- filtered_columns?,
- );
+ let filtered_batch: RecordBatch =
+ RecordBatch::new(self.schema.clone(), filtered_columns?);
Ok(Some(filtered_batch))
}