()
| 72 | } |
| 73 | |
| 74 | @Test |
| 75 | public void testGroupOptions() throws Exception { |
| 76 | pigServer.setBatchOn(); |
| 77 | pigServer.registerQuery("a = load 'tmp1' as (foo, bar);"); |
| 78 | pigServer.registerQuery("b = group a by foo;"); |
| 79 | pigServer.registerQuery("store b into 'tmp2';"); |
| 80 | |
| 81 | LOCogroup op = (LOCogroup)TestPigStats.getLogicalPlan(pigServer).findByAlias("b"); |
| 82 | assertFalse(op.isPinnedOption(LOCogroup.OPTION_GROUPTYPE)); |
| 83 | pigServer.discardBatch(); |
| 84 | |
| 85 | pigServer.setBatchOn(); |
| 86 | pigServer.registerQuery("a = load 'tmp' as (foo, bar);"); |
| 87 | pigServer.registerQuery("b = group a by foo using 'collected';"); |
| 88 | pigServer.registerQuery("store b into 'tmp2';"); |
| 89 | op = (LOCogroup)TestPigStats.getLogicalPlan(pigServer).findByAlias("b"); |
| 90 | assertTrue(op.isPinnedOption(LOCogroup.OPTION_GROUPTYPE)); |
| 91 | pigServer.discardBatch(); |
| 92 | } |
| 93 | } |
nothing calls this directly
no test coverage detected