[arrow-datafusion] branch master updated: Support NotLike in Ballista (#916)

[ho...@apache.org]

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

houqp 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 1dab962  Support NotLike in Ballista (#916)
1dab962 is described below

commit 1dab962841c4f4a1e5fd7230c634af80bc45376b
Author: Daniël Heres <da...@gmail.com>
AuthorDate: Sat Aug 21 21:20:34 2021 +0200

    Support NotLike in Ballista (#916)
---
 ballista/rust/core/src/serde/mod.rs | 1 +
 benchmarks/run.sh                   | 2 +-
 benchmarks/src/bin/tpch.rs          | 3 +++
 3 files changed, 5 insertions(+), 1 deletion(-)

diff --git a/ballista/rust/core/src/serde/mod.rs b/ballista/rust/core/src/serde/mod.rs
index 1df0675..1383ba8 100644
--- a/ballista/rust/core/src/serde/mod.rs
+++ b/ballista/rust/core/src/serde/mod.rs
@@ -98,6 +98,7 @@ pub(crate) fn from_proto_binary_op(op: &str) -> Result<Operator, BallistaError>
         "Multiply" => Ok(Operator::Multiply),
         "Divide" => Ok(Operator::Divide),
         "Like" => Ok(Operator::Like),
+        "NotLike" => Ok(Operator::NotLike),
         other => Err(proto_error(format!(
             "Unsupported binary operator '{:?}'",
             other
diff --git a/benchmarks/run.sh b/benchmarks/run.sh
index b1f47a2..9cbbf0e 100755
--- a/benchmarks/run.sh
+++ b/benchmarks/run.sh
@@ -20,7 +20,7 @@ set -e
 # This bash script is meant to be run inside the docker-compose environment. Check the README for instructions
 
 cd /
-for query in 1 3 5 6 7 10 12
+for query in 1 3 5 6 7 10 12 13
 do
   /tpch benchmark ballista --host ballista-scheduler --port 50050 --query $query --path /data --format tbl --iterations 1 --debug
 done
diff --git a/benchmarks/src/bin/tpch.rs b/benchmarks/src/bin/tpch.rs
index 29835e2..50fd40d 100644
--- a/benchmarks/src/bin/tpch.rs
+++ b/benchmarks/src/bin/tpch.rs
@@ -1147,7 +1147,10 @@ mod tests {
         test_round_trip!(q5, 5);
         test_round_trip!(q6, 6);
         test_round_trip!(q7, 7);
+        test_round_trip!(q8, 8);
+        test_round_trip!(q9, 9);
         test_round_trip!(q10, 10);
         test_round_trip!(q12, 12);
+        test_round_trip!(q13, 13);
     }
 }