周末做了一个小的练习，读取WINCC预先定义的用户，把名字填写在组合框里面。假设组合框名字叫做Userlist，在画面打开事件写下面的vbs脚本SubOnOpen()Dimfullusername,databasename,sqlconnstr,conn,sqlstr,objrs,usercount,userlist,ifullusername=HMIRuntime.Tags("@DatasourceNa

文章目录Flink系列文章一、maven依赖二、KeyedState1、KeyedState介绍及示例2、KeyedState状态有效期(TTL)1）、过期数据的清理2）、全量快照时进行清理3）、增量数据清理4）、在RocksDB压缩时清理3、keyedstate示例：实现地铁站哪个进站口人数最多1）、javabean2）、实现3）、验证本文

文章目录Flink系列文章一、watermark介绍1、watermark介绍2、Watermark策略简介3、使用Watermark策略4、处理空闲数据源5、自定义WatermarkGenerator1）、自定义周期性Watermark生成器2）、自定义标记Watermark生成器6、Watermark策略与Kafka连接器7、算子处理Watermark

packagemainimport( "fmt" "gorm.io/driver/mysql" "gorm.io/gorm" "math/rand" "sync" "time")//用户结构体typeUserstruct{ Idint Namestring Telstring Addressstring}

文章目录Flink系列文章一、maven依赖二、示例：每5s统计一次地铁进站每个入口人数1、实现1）、bean2）、实现2、验证三、示例：处理延迟数据超过能接受的时间，每10s统计一次地铁进站每个入口人数1、实现1）、javabean2）、实现2、验证本文介绍了FlinkWaterMark的基本用法以及超过最大延迟允