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
apache · Jun 4, 2021 · a0370b2 · a0370b2
1 parent c92079d
commit a0370b2
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git 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
@@ -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",