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-ballista.git
The following commit(s) were added to refs/heads/master by this push:
new 475c5bb4 Add all binary ops in serde (#210)
475c5bb4 is described below
commit 475c5bb4ab706dc856fa4a5fb76ac1b20d50a83e
Author: Andy Grove <[email protected]>
AuthorDate: Thu Sep 15 06:28:48 2022 -0600
Add all binary ops in serde (#210)
---
ballista/rust/core/src/serde/mod.rs | 12 +++++++++++-
1 file changed, 11 insertions(+), 1 deletion(-)
diff --git a/ballista/rust/core/src/serde/mod.rs
b/ballista/rust/core/src/serde/mod.rs
index 1548af18..8e2bc8c9 100644
--- a/ballista/rust/core/src/serde/mod.rs
+++ b/ballista/rust/core/src/serde/mod.rs
@@ -213,13 +213,23 @@ pub(crate) fn from_proto_binary_op(op: &str) ->
Result<Operator, BallistaError>
"Modulo" => Ok(Operator::Modulo),
"Like" => Ok(Operator::Like),
"NotLike" => Ok(Operator::NotLike),
+ "IsDistinctFrom" => Ok(Operator::IsDistinctFrom),
+ "IsNotDistinctFrom" => Ok(Operator::IsNotDistinctFrom),
+ "BitwiseAnd" => Ok(Operator::BitwiseAnd),
+ "BitwiseOr" => Ok(Operator::BitwiseOr),
+ "BitwiseShiftLeft" => Ok(Operator::BitwiseShiftLeft),
+ "BitwiseShiftRight" => Ok(Operator::BitwiseShiftRight),
+ "RegexIMatch" => Ok(Operator::RegexIMatch),
+ "RegexMatch" => Ok(Operator::RegexMatch),
+ "RegexNotIMatch" => Ok(Operator::RegexNotIMatch),
+ "RegexNotMatch" => Ok(Operator::RegexNotMatch),
+ "StringConcat" => Ok(Operator::StringConcat),
other => Err(proto_error(format!(
"Unsupported binary operator '{:?}'",
other
))),
}
}
-
impl From<protobuf::JoinSide> for JoinSide {
fn from(t: protobuf::JoinSide) -> Self {
match t {
