? 执行SQL语句
load data local infile '/data/tmp/bl_fact_mapping_pid2userid' into table bl_fx_sale.MAPPING_PID2USERID_TMP CHARACTER SET utf8
FIELDS TERMINATED BY '||' ESCAPED BY '\\\\' IGNORE 1 LINES
(PID,UserId,MatchDay,MatchCount);
drop table if exists bl_fx_sale.MAPPING_USERID2PID_TMP;
create table bl_fx_sale.MAPPING_USERID2PID_TMP like bl_fx_sale.MAPPING_USERID2PID; rename table bl_fx_sale.MAPPING_PID2USERID_TMP to bl_fx_sale.MAPPING_PID2USERID; ? CheckTaskStatus Job Entry:检测任务状态
任务状态的作用是用来标识任务的正确执行与否。
批次号:用来标识任务状态的批次。例如,今天的任务执行成功与否不能依靠昨天的任务标志。
批次号和任务状态,一般必不可少。
? TaskStatus Job Entry:设置任务状态
? Dummy(沉默)空操作
什么也不做
? Success
? Job参数(Paramters):
在Job设置中,给Job设置参数dayno,值是在执行脚本时传入。 ? Merge Join(关联记录)
关联记录之前数据必须有序,一般使用该步骤时,也要使用
41 / 42
? Abort(失败、终止)
42 / 42