zoukankan      html  css  js  c++  java
  • Elastic Search Java Api 创建索引结构,添加索引

    创建TCP客户端

    Client client = new TransportClient()
                 .addTransportAddress(new InetSocketTransportAddress(
                         "localhost", 9300));

    创建索引

    client.admin().indices().prepareCreate("pages").execute().actionGet();
    创建索引结构
    XContentBuilder builder=XContentFactory
                .jsonBuilder()
                .startObject()
                    .startObject("sina")
                    .startObject("properties")
                        .startObject("article_title")
                            .field("type", "string")
                            .field("store", "yes")
                            .field("analyzer","ik")
                            .field("index","analyzed")
                        .endObject()
                        .startObject("article_content")
                            .field("type", "string")
                            .field("store", "no")
                            .field("analyzer","ik")
                            .field("index","analyzed")
                        .endObject()
                        .startObject("article_url")
                            .field("type", "string")
                            .field("store", "yes")
                            .field("index","not_analyzed")
                        .endObject()
                    .endObject()
                .endObject()
            .endObject();
    PutMappingRequest mapping = Requests.putMappingRequest("pages").type("sina").source(builder);
    client.admin().indices().putMapping(mapping).actionGet();

    添加索引数据

    IndexResponse response = client.prepareIndex("pages", "sina", null)
            .setSource(jsonBuilder()
                .startObject()
                      .field("article_title", Bytes.toString(r.getValue("article".getBytes(), "title".getBytes())))
                       .field("article_content", Bytes.toString(r.getValue("article".getBytes(), "content".getBytes())))
                        .field("article_url", Bytes.toString(r.getValue("article".getBytes(), "url".getBytes())))
                   .endObject()
                   )
            .execute()
            .actionGet();
                
    client.close();
  • 相关阅读:
    TPLINK GPL code 简要分析
    Openwrt 初探
    物联网-手机远程控制家里的摄像头(3)
    物联网-手机远程控制家里的摄像头(2)
    lumia 520无法开机
    树莓派无法驱动移动硬盘
    Cannot Change Opencv Webcam Setting
    IIC协议理解(转)
    应用调试(六)记录回放输入子系统
    应用调试(五)侵入式SWI
  • 原文地址:https://www.cnblogs.com/yaomajor/p/7767058.html
Copyright © 2011-2022 走看看