ElasticSearch(ES)中的分片查询方式
原文地址:http://www.bubuko.com/infodetail-836737.html
Es查询的时候默认是随机从一些分片中查询数据,可以通过配置让es从某些分片中查询数据
1:_local
指查询操作会优先在本地节点有的分片中查询,没有的话再在其它节点查询。
2:_primary:指查询只在主分片中查询
3:_primary_first:指查询会先在主分片中查询,如果主分片找不到(挂了),就会在副本中查询。
4:_only_node:指在指定id的节点里面进行查询,如果该节点只有要查询索引的部分分片,就只在这部分分片中查找,所以查询结果可能不完整。如_only_node:123在节点id为123的节点中查询。
5:_prefer_node:nodeid 优先在指定的节点上执行查询
6:Custom (string) value:随机指定一个值就可以。
7:_shards:0,1,2,3,4:查询指定分片的数据
8:自定义:_only_nodes:nodeid1,nodeid2,nodeid3根据多个节点进行查询
Es默认没有提供这种查询方式,所以就只能修改源码了。
首先找到org.elasticsearch.cluster.routing.operation.plain.PlainOperationRouting这个类,es搜索时获取分片信息是通过这个类的。它的preferenceActiveShardIterator()方法就是根据条件来找出响应的分片。
看源码可知其主要是根据preference这个参数来决定取出的分片的。如果没有指定该参数,就随机抽取分片进行搜索。
下面的代码就是根据上面说的不同情况进行的一些判断,使用的switch case语句。
在里面多增加一项ONLY_NODES,这个可以接收多个节点id,这个参数需要配置到preference枚举类中,还要在这个类中的switch判断中判断参数_only_nodes。添加case语句。
接下来就需要完善PlainOperationRouting类中的case语句判断逻辑了。
首先获取传递过来的所有节点id,以逗号分割。获取一个节点id的数组,下面循环判断传递的节点是否存在,如果不存在就抛异常。
下面就返回一个方法的返回值,这个方法是需要我们自己实现的,这个方法可以参考上面的onlyNodeActiveInitializingShardsIt这个方法。
接下来完善onlyNodesActiveShardsIt这个方法,
这样的话就可以从用户指定的多个节点中获取数据。
把项目重新打包,放到服务器上重新启动。
ElasticSearch(ES)中的分片查询方式相关推荐
- JAVA操作ES中的BoolQueryBuilder 查询方法
一,创建es的连接 public TransportClient transportClient(){ Settings settings = Settings.builder() ...
- 达梦中的连接查询方式
达梦中的连接查询方式,全部参照官方文档. 查询语句中FROM子句包含多个表时,称为连接查询.生成连接查询的执行计划,需要考虑三方面因素:访问路径.连接方式.连接顺序. 访问路径指对于每张表采用何种方式 ...
- Hibernate中的QBC查询方式详解
Hibernate中的QBC查询方式详解 QBC:Query By Criteria,条件查询. 是一种更加面向对象化的查询的方式. 1.QBC简单查询 测试代码: package com.pipi. ...
- ES中实现分页查询数据并返回想要的字段
在日志收集系统中,最近需要通过httpclient获取es中的日志信息,所以学习了一些es的查询语句方面的用法: 分页 分页的本质 分页的本质是从"大的数据集"中取出一部分.比如1 ...
- es中主分片和副本分片
我们知道es中保存数据的时候是有主分片和副本分片的,那么副本分片的作用有哪些呢? 1.作为备份,防止主分片崩溃 2.分担查询请求,请求会在主分片和副本分片之间均匀分布 第一点:主副本之前角色的切换如何 ...
- ELK——ElasticSearch(ES) LogStash Kibana 范围查询 经纬度
Spring Boot 搭建 ELK,这才是正确看日志的方式! ES地理边界聚合官网 ES API官网 一.快速入门实战 二.核心语法集群高可用实战演练 三.集群架构原理与搜索技术深入 四.底层原理与 ...
- Django中多对多查询方式
使用版本python3.5+django1.11.4 创建django-admin startproject DjangoORM 创建App ./manage.py startapp ORM from ...
- ES中关联关系处理方式汇总
前言 本节主要介绍在ES中关联关系的处理方式. 一.方案汇总 根据<Elasticsearch权威指南>以及官网中的介绍,ES针对关联关系的处理主要有如下方式: 应用层关联 非规划化数据 ...
- Elasticsearch--进阶-进阶两种查询方式_request uri查询和query DSL查询---全文检索引擎ElasticSearch工作笔记009
然后我们再来去查询高级一点的检索 1.可以看到在es中,支持两种方式的查询,一种是基于rest request uri,把请求的信息,放到http的地址上. 2.第二种方式就是使用REST reque ...
最新文章
- 惊了!计算机视觉还可以这么玩?
- 编程沉思-做一款小巧而好用的截图软件
- 云计算究竟能帮你具体做些什么事?
- spring框架所有包解释
- 征战蓝桥 —— 2013年第四届 —— C/C++A组第5题——前缀判断
- JAVA反射机制及其原理实现
- 程序员操作系统推荐_为什么程序员要会 Linux
- 【BZOJ2330】【tyvj1785】【codevs2404】糖果,第一次的差分约束
- apple_Apple WWDC 2018主题总结
- 训练集和测试集样本分布一致性的判断方法
- linux 时间戳几字节,字节转换跟时间戳转换
- 教你控制阿里云OSS下载速度
- java memcmp_【转】 memcmp源码实现
- MWC 2018前瞻:三星华为诺基亚们会展示这些黑科技!
- Introdution(前言)
- 集成微信登入遇到问题
- 一枚程序媛的java人生—2018年年终总结
- idea项目中有jar包,java文件却引不进来
- Python经验总结
- 晨控CK-GW208-EC与欧姆龙PLC工业EtherCAT协议通讯指南