@@ -2694,42 +2694,42 @@ def _publish(sdf, topic, value, key, timestamp):
2694
2694
return _publish
2695
2695
2696
2696
@pytest .mark .parametrize (
2697
- "how, left, right , expected" ,
2697
+ "how, right, left , expected" ,
2698
2698
[
2699
2699
(
2700
2700
"inner" ,
2701
- {"left" : 1 },
2702
2701
{"right" : 2 },
2702
+ {"left" : 1 },
2703
2703
[({"left" : 1 , "right" : 2 }, b"key" , 2 , None )],
2704
2704
),
2705
2705
(
2706
2706
"inner" ,
2707
- {"left" : 1 },
2708
2707
None ,
2708
+ {"left" : 1 },
2709
2709
[],
2710
2710
),
2711
2711
(
2712
2712
"inner" ,
2713
- {"left" : 1 },
2714
2713
{},
2714
+ {"left" : 1 },
2715
2715
[],
2716
2716
),
2717
2717
(
2718
2718
"left" ,
2719
- {"left" : 1 },
2720
2719
{"right" : 2 },
2720
+ {"left" : 1 },
2721
2721
[({"left" : 1 , "right" : 2 }, b"key" , 2 , None )],
2722
2722
),
2723
2723
(
2724
2724
"left" ,
2725
- {"left" : 1 },
2726
2725
None ,
2726
+ {"left" : 1 },
2727
2727
[({"left" : 1 }, b"key" , 2 , None )],
2728
2728
),
2729
2729
(
2730
2730
"left" ,
2731
- {"left" : 1 },
2732
2731
{},
2732
+ {"left" : 1 },
2733
2733
[({"left" : 1 }, b"key" , 2 , None )],
2734
2734
),
2735
2735
],
@@ -2741,8 +2741,8 @@ def test_how(
2741
2741
assign_partition ,
2742
2742
publish ,
2743
2743
how ,
2744
- left ,
2745
2744
right ,
2745
+ left ,
2746
2746
expected ,
2747
2747
):
2748
2748
left_topic , right_topic = create_topic (), create_topic ()
@@ -2775,48 +2775,48 @@ def test_mismatching_partitions_fails(self, create_topic, create_sdf):
2775
2775
left_sdf .join (right_sdf )
2776
2776
2777
2777
@pytest .mark .parametrize (
2778
- "on_overlap, left, right , expected" ,
2778
+ "on_overlap, right, left , expected" ,
2779
2779
[
2780
2780
(
2781
2781
"keep-left" ,
2782
- {"A" : 1 },
2783
2782
None ,
2784
2783
{"A" : 1 },
2784
+ {"A" : 1 },
2785
2785
),
2786
2786
(
2787
2787
"keep-left" ,
2788
- {"A" : 1 , "B" : "left" },
2789
2788
{"B" : "right" , "C" : 2 },
2789
+ {"A" : 1 , "B" : "left" },
2790
2790
{"A" : 1 , "B" : "left" , "C" : 2 },
2791
2791
),
2792
2792
(
2793
2793
"keep-right" ,
2794
- {"A" : 1 },
2795
2794
None ,
2796
2795
{"A" : 1 },
2796
+ {"A" : 1 },
2797
2797
),
2798
2798
(
2799
2799
"keep-right" ,
2800
- {"A" : 1 , "B" : "left" },
2801
2800
{"B" : "right" , "C" : 2 },
2801
+ {"A" : 1 , "B" : "left" },
2802
2802
{"A" : 1 , "B" : "right" , "C" : 2 },
2803
2803
),
2804
2804
(
2805
2805
"raise" ,
2806
- {"A" : 1 },
2807
2806
None ,
2808
2807
{"A" : 1 },
2808
+ {"A" : 1 },
2809
2809
),
2810
2810
(
2811
2811
"raise" ,
2812
- {"A" : 1 },
2813
2812
{"B" : 2 },
2813
+ {"A" : 1 },
2814
2814
{"A" : 1 , "B" : 2 },
2815
2815
),
2816
2816
(
2817
2817
"raise" ,
2818
- {"A" : 1 , "B" : "left B" , "C" : "left C" },
2819
2818
{"B" : "right B" , "C" : "right C" },
2819
+ {"A" : 1 , "B" : "left B" , "C" : "left C" },
2820
2820
ValueError ("Overlapping columns: B, C." ),
2821
2821
),
2822
2822
],
@@ -2828,8 +2828,8 @@ def test_on_overlap(
2828
2828
assign_partition ,
2829
2829
publish ,
2830
2830
on_overlap ,
2831
- left ,
2832
2831
right ,
2832
+ left ,
2833
2833
expected ,
2834
2834
):
2835
2835
left_topic , right_topic = create_topic (), create_topic ()
0 commit comments