java - Spark Java DataFrame 中的合并列

Question

类似的还有posts在 Stack Overflow 上有同样的问题，但在 Java Spark Dataframe 上没有。

任何人都可以帮我做同样的事情，但是用java。

我尝试了发布的解决方案 here但它不适用于 Java。似乎合并函数需要 Scala.collections.seq<columns>作为类型。如何让它在 Java 中工作

Answer 1

我必须将列转换为 Seq 才能使其在 Java 8 中工作。

public Seq<Column> getSeqString(Column a, Column b)
    {
        ArrayList<Column> cols = new ArrayList<Column>();
        cols.add(a);
        cols.add(b);
        return scala.collection.JavaConverters.collectionAsScalaIterableConverter(cols).asScala().toBuffer();
    }