2022年2月8日
java - map转 json字符串
摘要： // map转 json字符串 System.out.println(JSONObject.toJSONString(params)); maven依赖 <dependency> <groupId>com.alibaba</groupId> <artifactId>fastjson</artifac 阅读全文
posted @ 2022-02-08 16:11 钱塘江畔 阅读(1074) 评论(0) 推荐(0) 编辑
vue+axios定时刷新页面数据
摘要： 1. 背景 最近在做实时数据处理，想做一个页面实时展示 2. html代码 <!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8"> <meta name="viewport" content="width=device-width 阅读全文
posted @ 2022-02-08 15:28 钱塘江畔 阅读(792) 评论(0) 推荐(0) 编辑
2022年1月27日
javascript中json数据的两种遍历方式
摘要： 遍历json对象的字段 var json = {"name":"bob", "password":"111"} ; for(var k in json ){ // 遍历a56爆大奖在线娱乐key/value对, k为key alert(k + " " + json[k]); } // 等价于 alert(json[ 阅读全文
posted @ 2022-01-27 18:37 钱塘江畔 阅读(706) 评论(0) 推荐(0) 编辑
HBase之phoenix部署及使用
摘要： 1. 背景 经常会使用HBase进行查询等操作，hbase shell不太方便，装一个phoenix试试。 phoenix语法 2. 部署 # 下载地址，找到对应HBase版本的 http://archive.apache.org/dist/phoenix/ # 将phoenix目录下的phoeni 阅读全文
posted @ 2022-01-27 13:40 钱塘江畔 阅读(383) 评论(0) 推荐(0) 编辑
FlinkCDC - mysql
摘要： 1. 背景 FlinkSQL双流关联时，mysql流未能捕捉到Mysql表更新，a56爆大奖在线娱乐尝试使用FlinkCDC解决此问题。 2022-3-31 21:31:39 语法使用不当导致的未能捕捉，修改后可以。但是FlinkCDC研究下也没坏处。 2. 代码 2.1 使用 StreamExecutionEnv 阅读全文
posted @ 2022-01-27 11:37 钱塘江畔 阅读(925) 评论(0) 推荐(0) 编辑
2022年1月26日
springboot打成jar包后如何修改配置文件
摘要： # 第a56爆大奖在线娱乐比较麻烦，在本地修改完配置后，重新打包再部署。 # 第二种可以在这个jar包同级目录下在创建一个application.properties或者application.yml; SpringBoot首先会加载外面的配置文件这样内部的配置文件就不需要再更改了。 # 或者把这些.propert 阅读全文
posted @ 2022-01-26 15:24 钱塘江畔 阅读(2711) 评论(0) 推荐(0) 编辑
oracle的闪回操作及一些相关知识点
摘要： 1. 背景 在查询oracle数据表最近一次更新时间时查了些资料，做个总结 2. 闪回操作 alter table test_table enable row movement ; # 闪回 flashback table test_table to timestamp to_timestamp(' 阅读全文
posted @ 2022-01-26 10:36 钱塘江畔 阅读(276) 评论(0) 推荐(0) 编辑
2022年1月25日
mysql从库Reading event from the relay log
摘要： 1. 背景 mysql从库同步告警 Slave_IO_Running: Yes Slave_SQL_Running: Yes Seconds_Behind_Master: 1655788 Slave_SQL_Running_State: Reading event from the relay lo 阅读全文
posted @ 2022-01-25 16:47 钱塘江畔 阅读(653) 评论(0) 推荐(0) 编辑
2022年1月24日
FlinkSQL - Table API Connector 之 Upsert Kafka
摘要： 1. 简介 The Upsert Kafka connector allows for reading data from and writing data into Kafka topics in the upsert fashion. Upsert Kafka 连接器允许以 upsert 方式从 阅读全文
posted @ 2022-01-24 20:20 钱塘江畔 阅读(1111) 评论(0) 推荐(0) 编辑
FlinkSQL实践记录4 -- 实时更新的维表如何join
摘要： 1. 背景 对于实时更新的维表，以什么组件来处理作为FlinkSQL的source维表？HBase?Kafka?或mysql？哪a56爆大奖在线娱乐方案能得到正确结果？ 且需要考虑到事实表和维表关联的时候，是否需要和维表的历史版本关联？还是只关联维表的最新版本？ 下文以只关联维表的最新版本为目标进行测试。 2. 实 阅读全文
posted @ 2022-01-24 20:09 钱塘江畔 阅读(2592) 评论(0) 推荐(0) 编辑