0

次のようなマップがあります。

 Map("index1" -> List["a", "b", "c"])

エラスティックに関する私のデータには、「名前」と呼ばれるフィールドがあります。スパークからエラスティック検索をクエリし、「名前」フィールドの値として「a」、「b」、「c」を持つすべてのレコードを返したいと思います。

エラスティック クエリで名前をハードコーディングしたくありません。

 session.read.format("org.elasticsearch.spark.sql")
  .option("es.query", query)
  .load(indexName)

文字列のリストを受け入れる動的クエリのフレーミングを誰かが手伝ってくれませんか。

4

1 に答える 1