Как создать индекс в Elasticsearch с использованием эластичного поиска-искры?

Question

Я хочу создать индекс в Elasticsearch из моей искровой трансформации. Интересно, каков наилучший способ сделать это с помощью библиотекиasticsearch-spark? С уважением

Answer 1

При записи в эластичный поиск он создаст индекс, если его нет

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")