信令与多级围栏匹配,匹配上的下发
dataservice.ubd_xl_realtime_geofence
map
process
dataStreamSource
围栏
keyBy(deviceNumber)
5min AGG
mysql
根据gepfenceType划分围栏等级,构建所有等级的围栏
5min内mergedCount最多的geoHash
/user/ubd_master/ubd_x_dwd.db/dwd_mi_signalling_internet_position_info
dataservice.ubd_xl_realtime_action_geofence_mapping
sink to kafka
dataservice.ubd_xl_realtime_action_test
按逻辑插入trackpoint,span style=\"font-size: inherit;\
BroadCastSource
file name
broadCast
broadCastProcess
list[map(字段名,字段值)]一条数据为一个map