| 72 | | v_sql := 'SELECT sid, name, $1 as rollup_time, SUM(1) as count_rows, (SUM(avg_value*1)/SUM(1)) as avg_value, (SUM(counter_dev*1)/SUM(1)) as counter_dev |
|---|
| 73 | | FROM stratcon.unroll_metric_numeric( $1, $2, $3) |
|---|
| 74 | | GROUP BY sid, name'; |
|---|
| 75 | | RAISE NOTICE 'v_sql was (%), %, %, %',v_sql,v_min_whence, v_min_whence + (v_conf.seconds - 1) * '1 second'::interval, v_conf.dependent_on; |
|---|
| 76 | | FOR v_rec IN EXECUTE v_sql USING v_min_whence, |
|---|
| 77 | | v_min_whence + (v_conf.seconds - 1) * '1 second'::interval, |
|---|
| 78 | | v_conf.dependent_on LOOP |
|---|
| | 68 | IF in_rollup = '5m' THEN |
|---|
| | 69 | v_sql := 'SELECT * FROM stratcon.window_robust_derive('||quote_literal(v_min_whence)||')'; |
|---|
| | 70 | ELSE |
|---|
| | 71 | v_sql := 'SELECT sid, name, '||quote_literal(v_min_whence)||' as rollup_time, SUM(1) as count_rows, (SUM(avg_value*1)/SUM(1)) as avg_value,'; |
|---|
| | 72 | v_sql := v_sql || ' (SUM(counter_dev*1)/SUM(1)) as counter_dev FROM stratcon.unroll_metric_numeric('||quote_literal(v_min_whence)||','; |
|---|
| | 73 | v_sql := v_sql || quote_literal(v_min_whence + (v_conf.seconds - 1) * '1 second'::interval) || ',' || quote_literal(v_conf.dependent_on) ||')'; |
|---|
| | 74 | v_sql := v_sql || ' GROUP BY sid, name'; |
|---|
| | 75 | |
|---|
| | 76 | -- v_sql := 'SELECT sid, name, $1 as rollup_time, SUM(1) as count_rows, (SUM(avg_value*1)/SUM(1)) as avg_value, (SUM(counter_dev*1)/SUM(1)) as counter_dev |
|---|
| | 77 | -- FROM stratcon.unroll_metric_numeric( $1, $2, $3) |
|---|
| | 78 | -- GROUP BY sid, name'; |
|---|
| | 79 | END IF; |
|---|
| | 80 | RAISE NOTICE 'v_sql was (%),v_sql; |
|---|
| | 81 | |
|---|
| | 82 | FOR v_rec IN EXECUTE v_sql LOOP |
|---|
