()
| 149 | |
| 150 | |
| 151 | def test_join_recursive(): |
| 152 | pdf = pd.DataFrame({"x": [1, 2, 3], "y": 1}, index=pd.Index([1, 2, 3], name="a")) |
| 153 | df = from_pandas(pdf, npartitions=2) |
| 154 | |
| 155 | pdf2 = pd.DataFrame( |
| 156 | {"a": [1, 2, 3, 4, 5, 6], "b": 1}, index=pd.Index([1, 2, 3, 4, 5, 6], name="a") |
| 157 | ) |
| 158 | df2 = from_pandas(pdf2, npartitions=2) |
| 159 | |
| 160 | pdf3 = pd.DataFrame({"c": [1, 2, 3], "d": 1}, index=pd.Index([1, 2, 3], name="a")) |
| 161 | df3 = from_pandas(pdf3, npartitions=2) |
| 162 | |
| 163 | result = df.join([df2, df3], how="outer") |
| 164 | assert_eq(result, pdf.join([pdf2, pdf3], how="outer")) |
| 165 | |
| 166 | result = df.join([df2, df3], how="left") |
| 167 | # The nature of our join might cast ints to floats |
| 168 | assert_eq(result, pdf.join([pdf2, pdf3], how="left"), check_dtype=False) |
| 169 | |
| 170 | |
| 171 | def test_join_recursive_raises(): |
nothing calls this directly
no test coverage detected