()
| 257 | } |
| 258 | |
| 259 | @Test |
| 260 | public void testJoin() throws Exception { |
| 261 | String query = |
| 262 | "a = load 'file:///tmp/input1' as (x:int, y:int);" + |
| 263 | "b = load 'file:///tmp/input2' as (x:int, z:int);" + |
| 264 | "c = join a by x, b by x;" + |
| 265 | "d = foreach c generate a::x as x, y, z;" + |
| 266 | "store d into 'file:///tmp/pigoutput';"; |
| 267 | |
| 268 | run(query, "test/org/apache/pig/test/data/GoldenFiles/tez/TEZC-Join-1.gld"); |
| 269 | } |
| 270 | |
| 271 | @Test |
| 272 | public void testBloomJoin() throws Exception { |