source: proiecte/PDAD/trunk/mediumevents/pig/mr/mediumevents_avg_mr.pig @ 154

-- This script processes medium length for events

-- author: cristina

raw = LOAD '$inputDir/event_trace.tab' USING PigStorage('\t') AS (event_id,component_id,node_id,platform_id,node_name,event_type,event_start_time,event_stop_time,event_end_reason);

-- build durations
duration = FOREACH raw GENERATE 'medium duration' as id, event_stop_time-event_start_time as dur;

-- group and average
grup = GROUP duration BY id;
rez = FOREACH grup GENERATE group, AVG(duration.dur) as avg;

STORE rez INTO '$outputDir' USING PigStorage();