flink job：MainFabCalculatedIndicatorApplication
原始数据入库
基于Run和window的实时indicator计算
mainfab_data_topic
flink job：MainFabWriteRawdataApplication
FLink jobMainFabRouterService
mainfab_tansform_data_topic
写文件功能
mainfab_B_drift_indicator_topic
mainfab_B_calculated_Indicator_topic
flink job：MainFabAlarmApplication
flink job：MainFabAutoLimitService
Trace Data
flink job：MainFabProcessEndApplication
mainfab_B_logistic_Indicator_topic
indicator入库
flink job：MainFabIndicatorApplication
HBASE
flink job：MainFabWriteRundataApplication
mainfab_rundata_data_topic
json格式的原始数据
mainfab_rawdata_data_topic
TSDB
分流（0 dwon time）
mainfab_B_window_data_topic
alrmhistory报表
mainfab_B_indicator_topic
YOYO/Email/SMS
flink job：MainFabTansformDataApplication
flink job：MainFabWriteAlarmHistoryService
Event Data（Run Data， Tool Summary）
flink job：MainFabLogisticIndicatorService
OCAP触发逻辑判断
mainfab_indicator_result_topic
run入库
HIVE
flink job：MainFabWindowEndApplication
复杂indicator实时计算
PT
alarm java 程序
flink job：MainFabAlarmWriteResultDataService
indicator OCAP data
mainfab_alarm_topic
flink job：MainFabFileService
触发OCAP的结果数据，json格式
flink job：MainFabDriftApplication
