我可以这样查询来自Spark的elasticsearch：

spark.read.format(
    "es"
).options(
    **{
        "es.index.auto.create": "true",
        'es.resource': index_name,
        'es.nodes.wan.only': 'true',
        'es.nodes': elasticsearch_host,
        'es.port': elasticsearch_port,
        'es.net.http.auth.user': elasticsearch_user,
        'es.net.http.auth.pass': elasticsearch_password,
        'es.query': query
    }
).load()

但是我怎样才能在map方法里面访问es呢？
就像这样：

df.rdd.map(
 lambda x: query_es({"match": {"name": x[1]}})
)