fmt

Author: tglanz

datafusion/physical-plan/src/joins/sort_merge_join/stream.rs

@@ -1584,7 +1584,7 @@ impl SortMergeJoinStream {
                     left_columns.extend(right_columns);
                     left_columns
                 }
-                _ => exec_err!("Did not expect join type {}", self.join_type)?
+                _ => exec_err!("Did not expect join type {}", self.join_type)?,
             };
 
             // Push the streamed/buffered batch joined nulls to the output

datafusion/physical-plan/src/joins/sort_merge_join/tests.rs

@@ -646,7 +646,6 @@ async fn join_right_one() -> Result<()> {
 
 #[tokio::test]
 async fn join_right_different_columns_count_with_filter() -> Result<()> {
-
     // select *
     // from t1
     // right join t2 on t1.b1 = t2.b1 and t1.a1 > t2.a2
@@ -706,7 +705,6 @@ async fn join_right_different_columns_count_with_filter() -> Result<()> {
 
 #[tokio::test]
 async fn join_left_different_columns_count_with_filter() -> Result<()> {
-
     // select *
     // from t2
     // left join t1 on t2.b1 = t1.b1 and t2.a2 > t1.a1
@@ -766,7 +764,6 @@ async fn join_left_different_columns_count_with_filter() -> Result<()> {
 
 #[tokio::test]
 async fn join_left_mark_different_columns_count_with_filter() -> Result<()> {
-
     // select *
     // from t2
     // left mark join t1 on t2.b1 = t1.b1 and t2.a2 > t1.a1
@@ -809,7 +806,8 @@ async fn join_left_mark_different_columns_count_with_filter() -> Result<()> {
         ])),
     );
 
-    let (_, batches) = join_collect_with_filter(left, right, on, filter, LeftMark).await?;
+    let (_, batches) =
+        join_collect_with_filter(left, right, on, filter, LeftMark).await?;
 
     // The output order is important as SMJ preserves sortedness
     // LeftMark returns all left rows with a boolean mark column
@@ -827,7 +825,6 @@ async fn join_left_mark_different_columns_count_with_filter() -> Result<()> {
 
 #[tokio::test]
 async fn join_right_mark_different_columns_count_with_filter() -> Result<()> {
-
     // select *
     // from t1
     // right mark join t2 on t1.b1 = t2.b1 and t1.a1 > t2.a2
@@ -870,7 +867,8 @@ async fn join_right_mark_different_columns_count_with_filter() -> Result<()> {
         ])),
     );
 
-    let (_, batches) = join_collect_with_filter(left, right, on, filter, RightMark).await?;
+    let (_, batches) =
+        join_collect_with_filter(left, right, on, filter, RightMark).await?;
 
     // The output order is important as SMJ preserves sortedness
     // RightMark returns all right rows with a boolean mark column