()
| 477 | } |
| 478 | |
| 479 | @Test |
| 480 | public void testMergeJoin3Way() throws IOException{ |
| 481 | try { |
| 482 | pigServer.registerQuery("A = LOAD '" + INPUT_FILE + "' as (id, name, n);"); |
| 483 | pigServer.registerQuery("B = LOAD '" + INPUT_FILE + "' as (id, name);"); |
| 484 | pigServer.registerQuery("C = LOAD '" + INPUT_FILE + "' as (id, name);"); |
| 485 | pigServer.registerQuery("D = join A by id, B by id, C by id using 'merge';"); |
| 486 | }catch(Exception e) { |
| 487 | PigException pe = LogUtils.getPigException(e); |
| 488 | Assert.assertTrue( pe.getMessage().contains( "Merge join can only be applied for 2-way joins" ) ); |
| 489 | return; |
| 490 | } |
| 491 | Assert.fail("Should throw exception, do not support 3 way join"); |
| 492 | } |
| 493 | |
| 494 | @Test |
| 495 | public void testMergeJoinWithOrderAndSplit() throws Exception{ |
nothing calls this directly
no test coverage detected