如何在不查询每个节点的情况下使用PySpark对Elasticsearch运行查询？

from pyspark.sql import SparkSession
from pyspark.sql.functions import *
from elasticsearch import Elasticsearch

spark = SparkSession.builder \
    .appName("Elasticsearch Query") \
    .getOrCreate()

es = Elasticsearch(hosts=["<elasticsearch_host>"])

df = spark.read.format("org.elasticsearch.spark.sql") \
    .option("es.nodes", "<elasticsearch_host>") \
    .option("es.resource", "<index>/<type>") \
    .load()

result = df.filter("<query_condition>").select("<columns>")

result.write.format("org.elasticsearch.spark.sql") \
    .option("es.nodes", "<elasticsearch_host>") \
    .option("es.resource", "<index>/<type>") \
    .mode("overwrite") \
    .save()

spark.stop()
es.close()