Flink原理，实战与性能优化读书笔记(四) watermark+window指定TimeStamp 与 生成 Watermarks两种方法指定：Source Function 直接定义 Timestamps 与 watermarkscollectWithTimestamp() 生成时间戳 第一个参数指数据，第二个参数是时间戳emitWatermark 创建watermark在addSource中

【代码】ES海量数据更新及导入导出备份。

一、机器学习中两大类问题一个是分类，一个是聚类。分类是监督学习，原始数据有标签，可以根据原始数据建立模型，确定新来的数据属于哪一类。聚类是一种无监督学习，聚类是指事先没有“标签”，在数据中发现数据对象之间的关系，将数据进行分组，一个分组也叫做“一个簇”，组内的相似性越大，组间的差别越大，则聚类效果越好，也就是簇内对象有较高的相似度，簇之间的对象相似度比较低，则聚类效果越好。K-me...

决策树和随机森林：决策树和随机森林都是非线性有监督的分类模型。决策树是一种树形结构，树内部每个节点表示一个属性上的测试，每个分支代表一个测试输出，每个叶子节点代表一个分类类别。通过训练数据构建决策树，可以对未知数据进行分类，随机森林是由多个决策树组成，随机森林中每一棵决策树之间没有关联，在得到一个随机森林后，当有新的样本进入的时候，随机森林中的每一棵决策树分别进行判断，分析出该样本属于哪一...

一、ps -ef|grep flink 和top -p pid 组合Linux下查看某一个进程所占用的内存，首先可以通过ps命令找到进程id，比如：ps -ef|grep flink，可以看到flink task这个程序的进程id已知pid是8678，现在可以使用如下命令查看内存：这样可以动态实时的看到CPU和内存的占用率，然后按q键回到命令行二、直接命令查看 ps -aux|grep flink

今早点了update project，天哪！顿时傻眼了。。本地部分代码文件消失了。。。后来百度发现，原来是可以回复的，，呼~ 吓死宝宝了如何回复呢？The first step，在project处右击，选择“Local History” --> “Show History” 。此时会弹出一个框，左侧你会看到自己的修改历史，右侧是对应修改的内容，选中需要恢复的历史版本，点击上方的Revert

一、基础知识篇Http Header之User-AgentUser Agent中文名为用户代理，是Http协议中的一部分，属于头域的组成部分，User Agent也简称UA。它是一个特殊字符串头，是一种向访问网站提供你所使用的浏览器类型及版本、操作系统及版本、浏览器内核、等信息的标识。通过这个标 识，用户所访问的网站可以显示不同的排版从而为用户提供更好的体验或者进行信息统计；例如用手机访问...

【代码】ES海量数据更新及导入导出备份。

一、机器学习中两大类问题一个是分类，一个是聚类。分类是监督学习，原始数据有标签，可以根据原始数据建立模型，确定新来的数据属于哪一类。聚类是一种无监督学习，聚类是指事先没有“标签”，在数据中发现数据对象之间的关系，将数据进行分组，一个分组也叫做“一个簇”，组内的相似性越大，组间的差别越大，则聚类效果越好，也就是簇内对象有较高的相似度，簇之间的对象相似度比较低，则聚类效果越好。K-me...

报错信息：2020-11-12 17:28:28 ERROR Thread-2 com.asiainfo.listener.RedisMessageListener 【接收到redis消息失败】org.springframework.data.redis.serializer.SerializationException: Could not read JSON: Unexpected token