写入HBase表CM_SUBSGPRSSTATUS_COUNT
time：该条数据的时间戳；htime：为对应状态值的时间戳
timehtime
s1!=s2
构建对应的rowkey
入库
计算EC增量值
更新HBase表：CM_SUBS_SUBSCRIBER表
依据行健聚合
kafka
汇合增量数据
计算群组增量值
GGSN
计算HBase库卡状态:s2
汇合卡属集合
否
批量查询cm_subsgprsstatus_count中指定的多列的Set集合，修改set
是
计算增量值
获取对应eccustid、operid、roleTypeId
解析数据
计算当前卡状态:s1
筛选eccustid!=null的集合
