如何使用elasticsearch-spark在Elasticsearch中创建索引？

Question

我想通过我的spark转换在Elasticsearch中创建一个索引。我想知道使用elasticsearch-spark库最好的方法是什么？亲切的问候

Answer 1

当写入elasticsearch时，如果不存在，它将创建一个索引

df.write
  .format("org.elasticsearch.spark.sql")
  .option("es.nodes.wan.only","true")
  .option("es.port","443")
  .option("es.nodes", esURL)
  .mode("Overwrite")
  .save("index/dogs")