舟山彭于晏 2022-06-15 12:31 采纳率: 66.7%
浏览 65
已结题

Es 通过javaapi的方式创建索引且字段加分词器时出现的错误

通过Java api 的方式创建索引,想着是对name字段设置对应的分词器,但是执行代码一直出错,也是第一次接触es,不知道怎么处理,什么地方的格式有问题

import org.apache.http.HttpHost;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.client.indices.CreateIndexRequest;
import org.elasticsearch.client.indices.CreateIndexResponse;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.xcontent.XContentBuilder;
import org.elasticsearch.common.xcontent.XContentFactory;
import org.junit.jupiter.api.Test;
import java.io.IOException;

//创建索引
public class creat_es_index {
private static final String IP = "IP地址";
private static final Integer Dk = 9200;
private static final String FWFS = "http";

@Test
public void esindex() throws IOException {
    //创建es客户端
    RestHighLevelClient restHighLevelClient = new RestHighLevelClient(
            RestClient.builder(new HttpHost(IP,Dk,FWFS))
    );
    CreateIndexRequest createIndexRequest = new CreateIndexRequest("ceshi");
    createIndexRequest.settings(Settings.builder()
            .put("number_of_shards", 3)
            .put("number_of_replicas", 0));
    XContentBuilder builder = XContentFactory.jsonBuilder();
    builder.startObject();{
        builder.startObject("properties");
        {
            // 流水号
            builder.startObject("name");
            {
                builder.field("type", "text").field("analyzer","ik_max_word");
            }
            builder.endObject();

            // 手机号
            builder.startObject("age");
            {
                builder.field("type", "keyword");
            }
            builder.endObject();

            // 发送时间
            builder.startObject("sex");
            {
                builder.field("type", "keyword");
            }
            builder.endObject();
        }
        builder.endObject();
    }
    builder.endObject();
    createIndexRequest.mapping(builder);
    CreateIndexResponse createIndexResponse = restHighLevelClient.indices().create(createIndexRequest, RequestOptions.DEFAULT);
    if (createIndexResponse.isAcknowledged()==true){
        System.out.println("索引创建成功");
    }else {
        System.out.println("索引创建失败");
    }
    //关闭es客户端
    restHighLevelClient.close();
}

}

运行结果及报错内容

img

希望有会的能指导一下

  • 写回答

1条回答

      报告相同问题?

      相关推荐 更多相似问题

      问题事件

      • 系统已结题 6月23日
      • 已采纳回答 6月15日
      • 创建了问题 6月15日

      悬赏问题

      • ¥15 边界图中的x、y轴解释
      • ¥30 如何用matlab求解复杂方程
      • ¥15 VUE TS中怎么调用第三方js
      • ¥15 Activiti如何将值传入textValue
      • ¥20 在linux里安装lummps时 在make mpi里找不到rpc
      • ¥25 python先到先得调度和轮询调度
      • ¥15 SDK Manager闪退
      • ¥15 intel i219v mac地址修改问题
      • ¥15 leetcode上面的题,求解
      • ¥15 PHP,访问接口500错误