From a0370b273c6dd4c972eadbee2c5465ac46a58fd9 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Dani=C3=ABl=20Heres?= <danielheres@gmail.com>
Date: Fri, 4 Jun 2021 18:37:15 +0200
Subject: [PATCH] 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 859cf350ca51..8f1480deedbc 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 66e6916b6815..8ceac64741e9 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",