Line | |
---|
1 | -- This script processes medium length for events |
---|
2 | |
---|
3 | -- author: cristina |
---|
4 | |
---|
5 | |
---|
6 | 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); |
---|
7 | |
---|
8 | -- build durations |
---|
9 | duration = FOREACH raw GENERATE 'medium duration' as id, event_stop_time-event_start_time as dur; |
---|
10 | |
---|
11 | -- group and average |
---|
12 | grup = GROUP duration BY id; |
---|
13 | rez = FOREACH grup GENERATE group, AVG(duration.dur) as avg; |
---|
14 | |
---|
15 | STORE rez INTO 'mediumevents_avg.rez' USING PigStorage(); |
---|
Note: See
TracBrowser
for help on using the repository browser.