flink1.12.x FlinkCEP-模式:.where()、begin()、next()、followedBy()
flink1.12.x FlinkCEP-处理匹配事件:select()、flatSelect()、process()
flink1.12.x Time分类-Event Time事件时间、Ingestion Time摄入时间、Processing Time处理时间
python selenium checkbox、radio勾选
flink1.12.x 水位线生成时机、分配器(Periodic Watermarks周期性分配水位线、Punctuated Watermarks定点水位线)
数据库schema、catalog介绍
flink1.12.x Table API 和 SQL:创建工程,读取csv文件,创建表,实现查询(connector连接器)
flink1.12.x SQL:创建工程,从socket读取数据,实现查询(DataStreamSource转View)
flink1.12.x Table API 和 SQL:从kafka读取数据,写入到elasticsearch,上传flink集群,flink run执行jar(独立集群模式)
flink1.12.x SQL:从socket读取数据,实现分组聚合查询(Retract)