0

2 つの異なる ES クラスターから 2 つの Rdd を結合する必要がありますが、1 つの ES クラスターに基づいて 1 つの SparkConf と SparkContext を作成するだけでよいことがわかりました。たとえば、次のようなコード:

var sparkConf: SparkConf = new SparkConf()
sparkConf.set("es.nodes", "192.168.0.22:9200")
val rdd1=sc.esRDD("userIndex1/type1")

では、異なる ES クラスターから 2 つの RDD を作成するにはどうすればよいでしょうか?

4

1 に答える 1

2

cfgのパラメータがありますesRDD。を使用val rdd1=sc.esRDD("userIndex1/type1", Map("es.nodes" -> "192.168.0.22:9200")して構成を設定できます。

于 2016-05-24T20:25:12.563 に答える