scala.collection.Seqは、Javaを使用した

Question

上では動作しません。 exampleは、scala.collection.Seqパラメータを使用してメソッド結合を使用して列名を指定します。しかし、私はそれを使用することはできません。彼らは、次の例を提供マニュアルの ：

df1.join(df2, Seq("user_id", "user_name")) 

エラー：シンボルメソッド配列（String）を見つけることができません

マイコード：

import org.apache.spark.sql.Dataset; 
import org.apache.spark.sql.Row; 
import scala.collection.Seq; 

public class UserProfiles { 

public static void calcTopShopLookup() { 
    Dataset<Row> udp = Spark.getDataFrameFromMySQL("my_schema","table_1"); 

    Dataset<Row> result = Spark.getSparkSession().table("table_2").join(udp,Seq("col_1","col_2")); 
} 

Answer 1

Seq(x, y, ...)がにScalaの方法です。シーケンスを作成します。 Seqはそれに対応するオブジェクトを持っています。これにはapplyメソッドがあり、毎回newを書き込むことはできません。

書くことができるようになります。

import scala.collection.JavaConversions; 
import scala.collection.Seq; 

import static java.util.Arrays.asList; 

Dataset<Row> result = Spark.getSparkSession().table("table_2").join(udp, JavaConversions.asScalaBuffer(asList("col_1","col_2")));` 

それとも、自分の小さなメソッドを作成することができます。

public static <T> Seq<T> asSeq(T... values) { 
     return JavaConversions.asScalaBuffer(asList(values)); 
    }