You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@arrow.apache.org by dh...@apache.org on 2021/06/04 16:37:26 UTC
[arrow-datafusion] branch master updated: Implement missing join
types for Python dataframe (#503)
This is an automated email from the ASF dual-hosted git repository.
dheres 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 a0370b2 Implement missing join types for Python dataframe (#503)
a0370b2 is described below
commit a0370b273c6dd4c972eadbee2c5465ac46a58fd9
Author: Daniël Heres <da...@gmail.com>
AuthorDate: Fri Jun 4 18:37:15 2021 +0200
Implement missing join types for Python dataframe (#503)
* Implement missing join types for Python dataframe
* Fix mapping
* Use commit hash instead
* undo some changes
* Remove imports
* Undo removed part
* Undo removed part
* minimize changes
---
python/Cargo.toml | 2 +-
python/src/dataframe.rs | 3 +++
2 files changed, 4 insertions(+), 1 deletion(-)
diff --git a/python/Cargo.toml b/python/Cargo.toml
index 859cf35..8f1480d 100644
--- a/python/Cargo.toml
+++ b/python/Cargo.toml
@@ -31,7 +31,7 @@ libc = "0.2"
tokio = { version = "1.0", features = ["macros", "rt", "rt-multi-thread", "sync"] }
rand = "0.7"
pyo3 = { version = "0.13.2", features = ["extension-module"] }
-datafusion = { git = "https://github.com/apache/arrow-datafusion.git", rev = "c3fc0c75af5ff2ebb99dba197d9d2ccd83eb5952" }
+datafusion = { git = "https://github.com/apache/arrow-datafusion.git", rev = "c92079dfb3045a9a46d12c3bc22361a44d11b8bc" }
[lib]
name = "datafusion"
diff --git a/python/src/dataframe.rs b/python/src/dataframe.rs
index 66e6916..8ceac64 100644
--- a/python/src/dataframe.rs
+++ b/python/src/dataframe.rs
@@ -147,6 +147,9 @@ impl DataFrame {
"inner" => JoinType::Inner,
"left" => JoinType::Left,
"right" => JoinType::Right,
+ "full" => JoinType::Full,
+ "semi" => JoinType::Semi,
+ "anti" => JoinType::Anti,
how => {
return Err(DataFusionError::Common(format!(
"The join type {} does not exist or is not implemented",