BAEL-9258: Concatenate Two Data Frames With the Same Column Name

apache-spark/src/main/java/com/baeldung/spark/dataframeconcat/ConcatRowsExample.java

@@ -0,0 +1,89 @@
+package com.baeldung.spark.dataframeconcat;
+
+import org.apache.spark.sql.Dataset;
+import org.apache.spark.sql.Row;
+import org.apache.spark.sql.SparkSession;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.Arrays;
+import java.util.List;
+
+public class ConcatRowsExample {
+
+    private static final Logger logger = LoggerFactory.getLogger(ConcatRowsExample.class);
+
+    public static void main(String[] args) {
+        SparkSession spark = SparkSession.builder()
+          .appName("Row-wise Concatenation Example")
+          .master("local[*]")
+          .getOrCreate();
+
+        try {
+            // Create sample data
+            List<Person> data1 = Arrays.asList(
+                new Person(1, "Alice"),
+                new Person(2, "Bob")
+            );
+
+            List<Person> data2 = Arrays.asList(
+                new Person(3, "Charlie"),
+                new Person(4, "Diana")
+            );
+
+            Dataset<Row> df1 = spark.createDataFrame(data1, Person.class);
+            Dataset<Row> df2 = spark.createDataFrame(data2, Person.class);
+
+            logger.info("First DataFrame:");
+            df1.show();
+
+            logger.info("Second DataFrame:");
+            df2.show();
+
+            // Row-wise concatenation using reusable method
+            Dataset<Row> combined = concatenateDataFrames(df1, df2);
+
+            logger.info("After row-wise concatenation:");
+            combined.show();
+        } finally {
+            spark.stop();
+        }
+    }
+
+    /**
+     * Concatenates two DataFrames row-wise using unionByName.
+     * This method is extracted for reusability and testing.
+     */
+    public static Dataset<Row> concatenateDataFrames(Dataset<Row> df1, Dataset<Row> df2) {
+        return df1.unionByName(df2);
+    }
+
+    public static class Person implements java.io.Serializable {
+        private int id;
+        private String name;
+
+        public Person() {
+        }
+
+        public Person(int id, String name) {
+            this.id = id;
+            this.name = name;
+        }
+
+        public int getId() {
+            return id;
+        }
+
+        public void setId(int id) {
+            this.id = id;
+        }
+
+        public String getName() {
+            return name;
+        }
+
+        public void setName(String name) {
+            this.name = name;
+        }
+    }
+}

apache-spark/src/test/java/com/baeldung/spark/dataframeconcat/ConcatRowsExampleUnitTest.java

@@ -0,0 +1,83 @@
+package com.baeldung.spark.dataframeconcat;
+
+import org.apache.spark.sql.Dataset;
+import org.apache.spark.sql.Row;
+import org.apache.spark.sql.SparkSession;
+import org.junit.jupiter.api.*;
+
+import java.util.Arrays;
+
+import static org.junit.jupiter.api.Assertions.*;
+
+class ConcatRowsExampleUnitTest {
+
+    private static SparkSession spark;
+    private Dataset<Row> df1;
+    private Dataset<Row> df2;
+
+    @BeforeAll
+    static void setupClass() {
+        spark = SparkSession.builder()
+          .appName("Row-wise Concatenation Test")
+          .master("local[*]")
+          .getOrCreate();
+    }
+
+    @BeforeEach
+    void setup() {
+        df1 = spark.createDataFrame(
+            Arrays.asList(
+                new ConcatRowsExample.Person(1, "Alice"),
+                new ConcatRowsExample.Person(2, "Bob")
+            ),
+            ConcatRowsExample.Person.class
+        );
+
+        df2 = spark.createDataFrame(
+            Arrays.asList(
+                new ConcatRowsExample.Person(3, "Charlie"),
+                new ConcatRowsExample.Person(4, "Diana")
+            ),
+            ConcatRowsExample.Person.class
+        );
+    }
+
+    @AfterAll
+    static void tearDownClass() {
+        spark.stop();
+    }
+
+    @Test
+    void givenTwoDataFrames_whenConcatenated_thenRowCountMatches() {
+        Dataset<Row> combined = ConcatRowsExample.concatenateDataFrames(df1, df2);
+
+        assertEquals(
+            4,
+            combined.count(),
+            "The combined DataFrame should have 4 rows"
+        );
+    }
+
+    @Test
+    void givenTwoDataFrames_whenConcatenated_thenSchemaRemainsSame() {
+        Dataset<Row> combined = ConcatRowsExample.concatenateDataFrames(df1, df2);
+
+        assertEquals(
+            df1.schema(),
+            combined.schema(),
+            "Schema should remain consistent after concatenation"
+        );
+    }
+
+    @Test
+    void givenTwoDataFrames_whenConcatenated_thenDataContainsExpectedName() {
+        Dataset<Row> combined = ConcatRowsExample.concatenateDataFrames(df1, df2);
+
+        assertTrue(
+          combined
+            .filter("name = 'Charlie'")
+            .count() > 0,
+          "Combined DataFrame should contain Charlie"
+        );
+    }
+}