次のようなマップがあります。
Map("index1" -> List["a", "b", "c"])
エラスティックに関する私のデータには、「名前」と呼ばれるフィールドがあります。スパークからエラスティック検索をクエリし、「名前」フィールドの値として「a」、「b」、「c」を持つすべてのレコードを返したいと思います。
エラスティック クエリで名前をハードコーディングしたくありません。
session.read.format("org.elasticsearch.spark.sql")
.option("es.query", query)
.load(indexName)
文字列のリストを受け入れる動的クエリのフレーミングを誰かが手伝ってくれませんか。