val originInfoDF = spark.sql("select col1, col2, col3, col4 from table_T")
val aggData = originInfoDF
                .groupBy("col1")
                .agg(collect_set(array("col2", "col3")), first("col4"))
                .toDF("c1", "c2", "c4")
                .map(line => {
                        val x = line.get... // 處理代碼
                        //如果返回22個以內(nèi), 直接返回 (x, y, z)
                        //如果超過22個, 該怎么寫來代替元組呢?
                })