4 years ago · b08845e0bb
--- a/data_collect/src/main/scala/com/persagy/iot/func/OriginalDataAlarm.scala
+++ b/data_collect/src/main/scala/com/persagy/iot/func/OriginalDataAlarm.scala
@@ -11,9 +11,9 @@ import org.apache.flink.util.Collector
 
				  * 1、正常数据，数据产生时间与实际入库的时间差小于 1800s
			
 
				  * 2、迟到数据，数据产生时间与实际入库的时间差大于 1800s，小于3600s
			
 
				  * 3、丢数
			
 
				- *  1、数据未到：state的时间触发器超过 3600s，侧输出流输出 rowKey 报警信息
			
 
				- *  2、数据已到：数据产生时间与实际入库的时间差大于 3600s
			
 
				- *  3、数据的产生时间如果是晚于进入系统时间，那么根据业务规则的阈值 3600s(暂定)，超过阈值的数据按异常数据处理
			
 
				+ *    a、数据未到：state的时间触发器超过 3600s，侧输出流输出 rowKey 报警信息
			
 
				+ *    b、数据已到：数据产生时间与实际入库的时间差大于 3600s
			
 
				+ *    c、数据的产生时间如果是晚于进入系统时间，那么根据业务规则的阈值 3600s(暂定)，超过阈值的数据按异常数据处理
			
 
				  */
			
 
				 class OriginalDataAlarm extends KeyedProcessFunction[String, IOTData, IOTData] {