2

2 つの個別の Elasticsearch クラスターがあり、最初のクラスターから 2 番目のクラスターにデータのインデックスを再作成したいのですが、次のように、SparkContext 構成内に 1 つの Elasticsearch クラスターしかセットアップできないことがわかりました。

var sparkConf : SparkConf = new SparkConf()
                     .setAppName("EsReIndex")
sparkConf.set("es.nodes", "node1.cluster1:9200")

では、同じアプリケーション内の Spark で Elastic search-hadoop を使用して 2 つの Elasticsearch クラスター間でデータを移動するにはどうすればよいでしょうか?

4

1 に答える 1