關於spark dataframe ，這裡介紹三種實用中實現可能比較麻煩的操作，首先上原始資料集 mRecord：

一，合併content列，將name相同的content合併到一行，用逗號隔開：

        mRecord.createOrReplaceTempView("test");
        val Df1 = sparkSQL.sql("select name,concat_ws(',',collect_set(content)) as contents from test group by name");
        Df1.show(false);

結果如下：

二、將contents列的內容根據逗號分隔成三列：

        val Df2 = Df1.withColumn("splitcol",split(col("contents"), ",")).select(
            col("splitcol").getItem(0).as("col1"),
            col("splitcol").getItem(1).as("col2"),
            col("splitcol").getItem(2).as("col3")
        ).drop("splitcol");
        Df2.show(false);

結果如下：

三、將一中的contents還原最初狀態，及將一列的內容根據逗號分隔成多行：

        val Df3 = Df1.withColumn("arrayCol",split(col("contents"),",")).withColumn("expCol",explode(col("arrayCol")));
        Df3.show(false);

結果如下：

注意expCol列的內容