- 博客(5)
- 问答 (1)
- 收藏
- 关注
RSS订阅原创 Elasticsearch 6.X批量更新nested嵌套体中的某一个字段值 _update_by_query
该文章在于解决elasticsearch6.x(6.8.12)的嵌套体中的某一个字段批量更新的问题我当前的所以为{"teacher_name":"xxx","age":40"students":["student_name":"xxx","student_age":10，"student_sex":"男" #或者女]}意为某一个老师的信息，嵌套体中是与这个老师相关的学生信息现在的需求是将这个表里的所有的student_sex=男的学生的年纪全部改为15post indexName
2021-11-29 14:19:11
2976
原创 Kafka: No entry found for connection 0
**kafka报错：**Kafka: No entry found for connection 0一般情况是kafka客户端的host文件没有配置映射，即使是用的ip连接，也是需要配置映射的例如 在host文件里添加kafka-node 10.159.x.xxx
2021-07-06 16:31:15
903
原创 使用scala调用Hbase API进行操作
使用scala调用Hbase API1：查看表是否存在def isTableExist(table: String): Boolean = { val conf: Configuration = HBaseConfiguration.create conf.set("hbase.zookeeper.quorum", "192.168.56.101,192.168.56.102,192.168.56.103") conf.set("hbase.zookeeper.property.
2021-01-07 17:19:02
605
1
原创 hive基础总结
1：创建外部表create external table if not exists employee_external(name string,work_palce array<string>,sex_age struct<sex:string,age:int>,depart_title map<string,array<string>>)comment 'this is an external table'row format delimi
2020-11-16 15:36:28
634
原创 Flume在Windows下启动报错[ERROR - org.apache.flume.lifecycle.LifecycleSupervisor$MonitorRunnable.run(Lifecy
Flume windows下启动报错[ERROR - org.apache.flume.lifecycle.LifecycleSupervisor$MonitorRunnable.run(LifecycleSupervisor.java:251)] Unable to start PollableSourceRunner: { source:Taildir source: { positionFile: position/test/test_log/position.json, skipToEnd: fal
2020-11-13 14:28:32
1568
空空如也
实时监控Oracle视图数据变化
2021-01-27
TA创建的收藏夹 TA关注的收藏夹
TA关注的人