文档章节

Elastic Search Java Api 创建索引结构,添加索引

从前
 从前
发布于 2015/03/06 16:24
字数 155
阅读 5610
收藏 10
创建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();



© 著作权归作者所有

从前

从前

粉丝 36
博文 75
码字总数 29813
作品 1
成都
程序员
私信 提问
加载中

评论(2)

从前
从前 博主

引用来自“shaozhengmao”的评论

请问楼主 .field("analyzer","ik") .field("index","analyzed") 这两个name的名字可以随便取吗,
我看有的教程写的是这样:.field("indexAnalyzer", "ik") .field("searchAnalyzer", "ik")
应该看看版本吧,.field("analyzer","ik")表示的分词器,这个需要看版本。 .field("index","analyzed")这个表示的该字段索引的方式,分词后索引,不能任意取
shaozhengmao
shaozhengmao
请问楼主 .field("analyzer","ik") .field("index","analyzed") 这两个name的名字可以随便取吗,
我看有的教程写的是这样:.field("indexAnalyzer", "ik") .field("searchAnalyzer", "ik")
在SpringBoot中使用Elasticsearch

一、SpringBoot模版方式接入(不建议) 其实一开始是准备用SpringBoot的模版来直接接入使用的,也就是以下这样的接入方式,也是网上大家都这么说的使用方式。 但是后面看java api的官方文档 De...

C6C
06/04
0
0
(一)ElasticSearch-入门

目录: 一.前言 二.安装 三.索引 四.搜索 五.聚合 六.分布式的特性 一.前言 Elasticsearch是一个基于Apache Lucene(TM)的开源搜索引擎。无论在开源还是专有领域,Lucene可以被认为是迄...

Deng_Wu
2018/08/16
0
0
Spring Data Elasticsearch使用

5.Spring Data Elasticsearch Elasticsearch提供的Java客户端有一些不太方便的地方: 很多地方需要拼接Json字符串,在java中拼接字符串有多恐怖你应该懂的 需要自己把对象序列化为json存储 ...

强某某
05/05
0
0
ElasticSearch使用

安装之前,请参考https://github.com/richardwilly98/elasticsearch-river-mongodb根据你的MongoDB版本号决定需要的elasticsearch版本号和插件号。 1)安装ES 下载ElasticSearch_版本号.tar....

强子哥哥
2014/04/09
0
0
Centos6搭建elk系统,监控IIS日志

**所需程序: 服务器端:java、elasticsearch、kikbana 客 户 端:IIS、logstash** 一、服务器端(192.168.10.46)操作: 先建立一个ELK专门的目录: [root@Cent65 ~]mkdir /elk/ 上传到elk...

D杀手D
2018/04/24
0
0

没有更多内容

加载失败,请刷新页面

加载更多

Vue-Ueditor

记录,忘了还要写啥了,先发吧,后面再补。。。 代码示例 import UEditor from '@/components/UE.vue';components: { UEditor },return {config: { //可以在此处定义工...

华山猛男
37分钟前
2
0
jupyter部署安装

python373 -m ipykernel install --name python373 ipython kernelspec list sc create myjupyterservice binpath="D:\apply\Python373\Scripts\jupyter-notebook --config=V:/my_work/jupyt......

mbzhong
51分钟前
4
0
聊聊feign的Contract

序 本文主要研究一下feign的Contract Contract feign-core-10.2.3-sources.jar!/feign/Contract.java public interface Contract { /** * Called to parse the methods in the class t......

go4it
今天
3
0
Linux 软链接和硬链接简介

本文主要介绍了Linux系统中的链接文件。 文件系统 在Linux系统中,将文件分为两个部分:用户数据和元数据。 元数据(inode) 元数据即文件的索引节点(inode),用来记录文件的权限(r、w、x...

问题终结者
今天
5
0
RocketMQ的事务投递

RocketMQ的事务投递 这是阿里的分布式事务图: 1、A服务先发送个Half Message给Brock端,消息中携带 B服务 即将要+100元的信息。 2、当A服务知道Half Message发送成功后,那么开始第3步执行本...

春哥大魔王的博客
今天
3
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部