JavaEsSparkSQL.esDF API文档

JavaEsSparkSQL.esDF API 是一个与 Elasticsearch 进行交互的 Java API，用于将 Elasticsearch 中的数据读入 Spark SQL DataFrame 中。下面是该 API 的详细文档：

## 方法

### esDF(sparkSession: SparkSession, resource: String): Dataset<Row>

读取 Elasticsearch 中的数据并将其转换为 Spark SQL DataFrame。

参数：

- `sparkSession`：SparkSession 对象。
- `resource`：Elasticsearch 中的索引或搜索查询。

返回值：

- `Dataset<Row>`：表示 Elasticsearch 中数据的 Spark SQL DataFrame。

## 示例

以下示例展示如何使用 esDF API 从 Elasticsearch 中读取数据并将其转换为 Spark SQL DataFrame。

import org.apache.spark.sql.Dataset;
import org.apache.spark.sql.Row;
import org.apache.spark.sql.SparkSession;

import static org.elasticsearch.spark.sql.api.java.JavaEsSparkSQL.esDF;

public class ReadFromElasticsearch {
    public static void main(String[] args) {
        SparkSession spark = SparkSession.builder()
                .appName("ReadFromElasticsearch")
                .master("local[*]")
                .config("es.nodes", "localhost")
                .config("es.port", "9200")
                .getOrCreate();

        Dataset<Row> df = esDF(spark, "index_name/_search?q=*");

        df.show();
    }
}

在上面的示例中，我们使用 esDF API 从 Elasticsearch 中读取名为 `index_name` 的索引的所有文档，并将其转换为 Spark SQL DataFrame。最后，我们使用 `show()` 方法显示 DataFrame 中的数据。