You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@arrow.apache.org by ag...@apache.org on 2022/11/16 16:48:36 UTC

[arrow-datafusion] branch master updated: remove duplicate or redundant code (#4235)

This is an automated email from the ASF dual-hosted git repository.

agrove pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/arrow-datafusion.git


The following commit(s) were added to refs/heads/master by this push:
     new b7a33c989 remove duplicate or redundant code (#4235)
b7a33c989 is described below

commit b7a33c9897ddf468ea0801fcac5eecb455f8780a
Author: jakevin <ja...@gmail.com>
AuthorDate: Thu Nov 17 00:48:30 2022 +0800

    remove duplicate or redundant code (#4235)
    
    * remove duplicate code
    
    * typo
    
    * remove
    
    * typo
---
 datafusion/optimizer/src/eliminate_filter.rs                   | 10 +++++-----
 datafusion/optimizer/src/filter_push_down.rs                   |  2 +-
 .../optimizer/src/simplify_expressions/expr_simplifier.rs      |  5 -----
 .../optimizer/src/simplify_expressions/simplify_exprs.rs       |  4 ++--
 datafusion/optimizer/src/simplify_expressions/utils.rs         |  4 ++--
 5 files changed, 10 insertions(+), 15 deletions(-)

diff --git a/datafusion/optimizer/src/eliminate_filter.rs b/datafusion/optimizer/src/eliminate_filter.rs
index 04f6f00f8..d5cbcf394 100644
--- a/datafusion/optimizer/src/eliminate_filter.rs
+++ b/datafusion/optimizer/src/eliminate_filter.rs
@@ -87,7 +87,7 @@ mod tests {
     }
 
     #[test]
-    fn fliter_false() {
+    fn filter_false() {
         let filter_expr = Expr::Literal(ScalarValue::Boolean(Some(false)));
 
         let table_scan = test_table_scan().unwrap();
@@ -105,7 +105,7 @@ mod tests {
     }
 
     #[test]
-    fn fliter_false_nested() {
+    fn filter_false_nested() {
         let filter_expr = Expr::Literal(ScalarValue::Boolean(Some(false)));
 
         let table_scan = test_table_scan().unwrap();
@@ -133,7 +133,7 @@ mod tests {
     }
 
     #[test]
-    fn fliter_true() {
+    fn filter_true() {
         let filter_expr = Expr::Literal(ScalarValue::Boolean(Some(true)));
 
         let table_scan = test_table_scan().unwrap();
@@ -151,7 +151,7 @@ mod tests {
     }
 
     #[test]
-    fn fliter_true_nested() {
+    fn filter_true_nested() {
         let filter_expr = Expr::Literal(ScalarValue::Boolean(Some(true)));
 
         let table_scan = test_table_scan().unwrap();
@@ -180,7 +180,7 @@ mod tests {
     }
 
     #[test]
-    fn fliter_from_subquery() {
+    fn filter_from_subquery() {
         // SELECT a FROM (SELECT a FROM test WHERE FALSE) WHERE TRUE
 
         let false_filter = lit(false);
diff --git a/datafusion/optimizer/src/filter_push_down.rs b/datafusion/optimizer/src/filter_push_down.rs
index eed833cf2..7bcd03565 100644
--- a/datafusion/optimizer/src/filter_push_down.rs
+++ b/datafusion/optimizer/src/filter_push_down.rs
@@ -1304,7 +1304,7 @@ mod tests {
             .filter(col("a").lt_eq(lit(1i64)))?
             .build()?;
 
-        let plan = crate::test::user_defined::new(plan);
+        let plan = user_defined::new(plan);
 
         let expected = "\
             TestUserDefined\
diff --git a/datafusion/optimizer/src/simplify_expressions/expr_simplifier.rs b/datafusion/optimizer/src/simplify_expressions/expr_simplifier.rs
index 40285eedc..b32fc53db 100644
--- a/datafusion/optimizer/src/simplify_expressions/expr_simplifier.rs
+++ b/datafusion/optimizer/src/simplify_expressions/expr_simplifier.rs
@@ -1001,11 +1001,6 @@ mod tests {
         let expr = call_fn("to_timestamp", vec![col("a")]).unwrap();
         test_evaluate(expr.clone(), expr);
 
-        // check that non foldable arguments are folded
-        // to_timestamp(a) --> to_timestamp(a) [no rewrite possible]
-        let expr = call_fn("to_timestamp", vec![col("a")]).unwrap();
-        test_evaluate(expr.clone(), expr);
-
         // volatile / stable functions should not be evaluated
         // rand() + (1 + 2) --> rand() + 3
         let fun = BuiltinScalarFunction::Random;
diff --git a/datafusion/optimizer/src/simplify_expressions/simplify_exprs.rs b/datafusion/optimizer/src/simplify_expressions/simplify_exprs.rs
index eaa34c08d..eecda9809 100644
--- a/datafusion/optimizer/src/simplify_expressions/simplify_exprs.rs
+++ b/datafusion/optimizer/src/simplify_expressions/simplify_exprs.rs
@@ -552,7 +552,7 @@ mod tests {
         let table_scan = test_table_scan();
 
         let ts_string = "2020-09-08T12:05:00+00:00";
-        let time = chrono::Utc.timestamp_nanos(1599566400000000000i64);
+        let time = Utc.timestamp_nanos(1599566400000000000i64);
 
         //  cast(now() as int) < cast(to_timestamp(...) as int) + 50000_i64
         let plan =
@@ -580,7 +580,7 @@ mod tests {
         let table_scan = test_table_scan();
 
         let ts_string = "2020-09-08T12:05:00+00:00";
-        let time = chrono::Utc.timestamp_nanos(1599566400000000000i64);
+        let time = Utc.timestamp_nanos(1599566400000000000i64);
 
         //  now() < cast(to_timestamp(...) as int) + 5000000000
         let schema = table_scan.schema();
diff --git a/datafusion/optimizer/src/simplify_expressions/utils.rs b/datafusion/optimizer/src/simplify_expressions/utils.rs
index 4df3f507d..c6c13c033 100644
--- a/datafusion/optimizer/src/simplify_expressions/utils.rs
+++ b/datafusion/optimizer/src/simplify_expressions/utils.rs
@@ -15,7 +15,7 @@
 // specific language governing permissions and limitations
 // under the License.
 
-//! Utitity functions for expression simplification
+//! Utility functions for expression simplification
 
 use arrow::datatypes::DECIMAL128_MAX_PRECISION;
 
@@ -171,7 +171,7 @@ pub fn as_bool_lit(expr: Expr) -> Result<Option<bool>> {
 
 /// negate a Not clause
 /// input is the clause to be negated.(args of Not clause)
-/// For BinaryExpr, use the negator of op instead.
+/// For BinaryExpr, use the negation of op instead.
 ///    not ( A > B) ===> (A <= B)
 /// For BoolExpr, not (A and B) ===> (not A) or (not B)
 ///     not (A or B) ===> (not A) and (not B)