Method setUp

test/org/apache/pig/test/TestForEach.java:56–72

()

    DataBag projDB;

    @Before
    public void setUp() throws Exception {
        Random r = new Random();
        db = GenRandomData.genRandSmallTupDataBagWithNulls(r, 10, 100);
        projDB = TestHelper.projectBag(db, 0);
        fe = GenPhyOp.topForEachOPWithPlan(0, db.iterator().next());
        POProject proj = GenPhyOp.exprProject();
        proj.setColumn(0);
        proj.setResultType(DataType.TUPLE);
        proj.setOverloaded(true);
        Tuple t = new DefaultTuple();
        t.append(db);
        proj.attachInput(t);
        List<PhysicalOperator> inputs = new ArrayList<PhysicalOperator>();
        inputs.add(proj);
        fe.setInputs(inputs);
    }

    @Test
    public void testGetNextTuple() throws ExecException, IOException {