()
| 235 | } |
| 236 | |
| 237 | @Test |
| 238 | public void testFilter() throws Exception { |
| 239 | String query = |
| 240 | "a = load 'file:///tmp/input' as (x:int, y:int);" + |
| 241 | "b = filter a by x > 0;" + |
| 242 | "c = foreach b generate y;" + |
| 243 | "store c into 'file:///tmp/pigoutput';"; |
| 244 | |
| 245 | run(query, "test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Filter-1.gld"); |
| 246 | } |
| 247 | |
| 248 | @Test |
| 249 | public void testGroupBy() throws Exception { |