IDMAPPING业务逻辑实现
2016-10-16 17:34:02 0 举报分享
作者其他创作
大纲/内容
文件下载
status更新6
条件检查
status更新为-1，任务失败
数据类型、加密方式（输入和输出）
YES
实时监控，获取status=0的task
status更新10
JOIN
HDFS
task入库
status更新为1
status更新为2，任务开始
数据文件
去重(整行去重，各指标去重)，组合DF
status更新4
对信息做处理，增加字段：task id，tasktype，taskstatus等
NO
count各参数
文件查看
常驻Thread
status更新8
保存文件到HDFS
收藏
收藏
0 条评论
下一页
