スパーク2（java）でブロードキャスト変数を作成する方法は？スパーク1では

Question

我々は、Spark放送変数を作成するには、以下のコードを使用することができます：

SparkConf conf = new SparkConf(); 
conf.set("spark.serializer", "org.apache.spark.serializer.KryoSerializer"); 

JavaSparkContext sc = new JavaSparkContext("local", "JavaAPISuite", conf); 

ArrayList<Strin'valuesg> sampleList = new ArrayList<String>(); 
sampleList.add("value"); 

final Broadcast<ArrayList<String> broadcastVar = sc.broadcast(sampleList); 

はどのように我々は、以下に示すAPIを使用してスパーク2で同じことを行うことができますか？例えば

SparkSession sc = SparkSession.setappName("SparkApp").getorcreate(); 
sc.sparkcontext().broadcast(T value, scala.reflect.ClassTag<T> evidence$11) 

Answer 1

あなたはTestという名前のクラスをブロードキャストしたい場合には、java.io.Serializableを実装して、あなたが行う必要があります。

import scala.reflect.ClassTag; 

ClassTag<Test> classTagTest = scala.reflect.ClassTag$.MODULE$.apply(Test.class); 
Broadcast<Test> broadcastTest = sc.sparkcontext().broadcast(new Test(), classTagTest);