SparkSQL reads from Elasticsearch a class exception

阅读量：

环境

软件	版本
Elasticsearch	2.3.3
spark	cdh-1.6.0
idea	2016

问题描述：

当前存在一个Elasticsearch集群，需通过SparkSQL直接进行数据读取操作。依据Elasticsearch官方提供的代码示例，编写如下程序实现数据读取功能（程序在Windows系统环境下开发，并提交至远程的Spark Standalone集群执行）：

复制代码

    public class TestDirectReadForQuery {
    public static void main(String[] args){
        String esTable = "twitter/doc"; //
        String query = "select * from "+esTable+" limit 10";
    
        HashMap<String, String> options = new HashMap<String, String>();
        options.put("es.nodes", "192.168.0.78"); // ES环境IP之一
        options.put("es.port", "9200"); //

全部评论 (0)

还没有任何评论哟~