|
| 1 | + |
1 | 2 | WITH ndtLegacy AS ( |
2 | | - SELECT NET.SAFE_IP_FROM_STRING(connection_spec.client_ip) AS ip, 8 * (web100_log_entry.snap.HCThruOctetsAcked / (web100_log_entry.snap.SndLimTimeRwin + web100_log_entry.snap.SndLimTimeCwnd + web100_log_entry.snap.SndLimTimeSnd)) AS mbps |
3 | | - FROM `measurement-lab.ndt.downloads` |
4 | | - WHERE partition_date BETWEEN DATE("{YEAR}-01-01") AND DATE("{YEAR}-12-31") |
| 3 | + SELECT NET.SAFE_IP_FROM_STRING(raw.connection.client_ip) AS ip, |
| 4 | + a.MeanThroughputMbps AS mbps |
| 5 | + FROM `measurement-lab.ndt.web100` |
| 6 | + WHERE DATE BETWEEN ("{YEAR}-01-01") AND DATE("{YEAR}-12-31") |
| 7 | + AND a.MeanThroughputMbps IS NOT NULL |
5 | 8 | ), |
6 | 9 | ndt5 AS ( |
7 | | - SELECT NET.SAFE_IP_FROM_STRING(result.S2C.ClientIP) AS ip, result.S2C.MeanThroughputMbps AS mbps |
| 10 | + SELECT NET.SAFE_IP_FROM_STRING(raw.ClientIP) AS ip, |
| 11 | + a.MeanThroughputMbps AS mbps |
8 | 12 | FROM `measurement-lab.ndt.ndt5` |
9 | | - WHERE partition_date BETWEEN DATE("{YEAR}-01-01") AND DATE("{YEAR}-12-31") |
10 | | - AND result.S2C IS NOT NULL |
| 13 | + WHERE DATE BETWEEN ("{YEAR}-01-01") AND DATE("{YEAR}-12-31") |
| 14 | + AND a.MeanThroughputMbps IS NOT NULL |
| 15 | +), |
| 16 | +ndt7 AS ( |
| 17 | + SELECT NET.SAFE_IP_FROM_STRING(raw.ClientIP) AS ip, |
| 18 | + a.MeanThroughputMbps AS mbps |
| 19 | + FROM `measurement-lab.ndt.ndt7` |
| 20 | + WHERE DATE BETWEEN ("{YEAR}-01-01") AND DATE("{YEAR}-12-31") |
| 21 | + AND a.MeanThroughputMbps IS NOT NULL |
11 | 22 | ), |
12 | 23 | unifiedndt AS ( |
13 | 24 | SELECT * FROM ndt5 |
14 | 25 | UNION ALL |
15 | 26 | SELECT * FROM ndtLegacy |
| 27 | + UNION ALL |
| 28 | + SELECT * FROM ndt7 |
16 | 29 | ), |
17 | 30 | ndtv4 AS ( |
18 | 31 | SELECT NET.IP_TRUNC(ip, 24) AS netblock, ip, mbps |
|
0 commit comments