从clickhouse迁移到StarRocks，研究讨论后，决定使用flink进行kafka同步到StarRocks。StarRocks可以选择固定分区和动态分区，考虑到数据增长，故选按天进行动态分区。4、写同步数据的flink sql，配置source和sink。4、使用mybatis的多数据源框架，配置多数据源进行查询。因数据都是日志类数据，帮选择了Duplicate。连接StarRocks可

package mainimport ("context""fmt""github.com/olivere/elastic/v7")type Person struct {Namestring `json:"name"`Ageint`json:"age"`Married bool`json:"married"`}func main() {client, err := elastic.NewClie

spring boot的配置文件中，一般会配置一些中间件的密码，比如：redis，mq，数据库，这对于安全性有要求的公司，不允许这么操作。想对项目代码改动较小的话，可以试试jasypt.本文以3.0为例，2.0版本会有所不一样，在加密算法上.1、在maven的pom.xml中加入依赖<dependency><groupId>com.github.ulisesbocchio&

去重指定字段

POST esindex/_doc/id/_update{"script" : "ctx._source.bussinesData.remark='test'",}es的restful接口UpdateRequest updateRequest = new UpdateRequest(dto.getEsIndex(), dto.getId());Map<String, Object> p

//查询前缀包含的内容POST /products/_search{"query": {"prefix": {"desc.keyword": {"value": "iP"}}}}POST /products/_search{"query": {"term": {"productID.keyword": "XHDK-A-1293-#fJ3"}}}//不查询为空的数据.

es的bool查询

clickhouse系统里面自带了query_log和query_thread_log表，这两个表不清除的话，时间久了，会挺大的，可以通过设置ttl时间来处理保存一个月的数据ALTER TABLE query_log MODIFY TTL event_date + toIntervalMonth(1);ALTER TABLE query_thread_log MODIFY TTL event_da