赞
踩
Java 写入 ES,可以使用 的 Java API 来实现。下面是一个示例代码:
Java 写入 ES,可以使用 Elasticsearch 的 Java API 来实现。下面是一个示例代码:
-
- java
- // 创建客户端
- Settings settings = Settings.builder().put("cer.name", "my-application").build();
- Transport client = new PreBuiltTransport(settings)
- .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("localhost"), 9300));
- // 创建索引
- CreateIndexRequest request = new CreateIndexRequest("myindex");
- CreateIndexResponse createIndexResponse = client.admin().indices().create(request).actionGet();
- // 创建文档
- Map json = new HashMap();
- json.put("user","kimchy");
- json.put("postDate",new Date());
- json.put("message","trying out Elasticsearch");
- IndexResponse response = client.prepareIndex("myindex", "tweet")
- .setSource(json)
- .get();
- // 关闭客户端
- client.close();
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。