(boolean withNulls)
| 63 | } |
| 64 | |
| 65 | private void setUpProjFil(boolean withNulls) throws Exception { |
| 66 | if (withNulls) |
| 67 | inp = GenRandomData.genRandSmallTupDataBagWithNulls(r, 10, 100); |
| 68 | else |
| 69 | inp = GenRandomData.genRandSmallTupDataBag(r, 10, 100); |
| 70 | t = GenRandomData.genRandSmallBagTuple(r, 10, 100); |
| 71 | projFil = GenPhyOp.topFilterOpWithProj(1, 50); |
| 72 | POProject inpPrj = GenPhyOp.exprProject(); |
| 73 | Tuple tmpTpl = new DefaultTuple(); |
| 74 | tmpTpl.append(inp); |
| 75 | inpPrj.setColumn(0); |
| 76 | inpPrj.setResultType(DataType.TUPLE); |
| 77 | inpPrj.setOverloaded(true); |
| 78 | inpPrj.attachInput(tmpTpl); |
| 79 | List<PhysicalOperator> inputs = new ArrayList<PhysicalOperator>(); |
| 80 | inputs.add(inpPrj); |
| 81 | projFil.setInputs(inputs); |
| 82 | } |
| 83 | |
| 84 | @Test |
| 85 | public void testGetNextTuple() throws Exception { |
no test coverage detected