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

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条回答 默认 最新

  • 皮蛋不吃粥 2022-06-15 13:10
    关注

    es上面安装了ik分词器了么

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论

报告相同问题?

问题事件

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

悬赏问题

  • ¥20 matlab有约束条件下的多元函数求最小值
  • ¥50 如何隐藏网页弹出框的url地址栏
  • ¥20 metropolis算法模拟二维ising模型来计算磁化强度,fortran
  • ¥15 uniapp-typescript-vue报错
  • ¥15 oracle强制关机以后报错01033
  • ¥15 给Chat with RTX添加语言模型时遇到问题
  • ¥15 oracle修复,怎么根据日志修复呀?
  • ¥15 使用Stable Diffusion时出现错误
  • ¥15 请教含粗糙度的点接触润滑问题
  • ¥100 需要3万组微信数据,昵称+头像+朋友圈背景