Package org.apache.pig.pigunit

Examples of org.apache.pig.pigunit.PigTest.runScript()


                                 "QUANTILES='0.5','0.75','1.0'");

    String[] input = {"1","2","3","4","10","5","6","7","8","9"};
    writeLinesToFile("input", input);
       
    test.runScript();
   
    List<Tuple> output = getLinesForAlias(test, "data_out", true);
   
    assertEquals(output.size(),1);
    assertEquals(output.get(0).toString(), "(5.0,8.0,10.0)");
View Full Code Here


      input.add(Integer.toString(i));
    }
   
    writeLinesToFile("input", input.toArray(new String[0]));
       
    test.runScript();
   
    List<Tuple> output = getLinesForAlias(test, "data_out", true);
   
    assertEquals(output.size(),1);
    assertEquals(output.get(0).toString(), "(70.0,30.0,370.0,1000.0,1.0)");
View Full Code Here

      input.add(Integer.toString(i));
    }
   
    writeLinesToFile("input", input.toArray(new String[0]));
       
    test.runScript();
   
    List<Tuple> output = getLinesForAlias(test, "data_out", true);
   
    assertEquals(output.size(),1);
    assertEquals(output.get(0).toString(), "(130.0,2280.0,15870.0,50000.0,84130.0,97720.0,99870.0)");
View Full Code Here

      input.add(Integer.toString(i));
    }
   
    writeLinesToFile("input", input.toArray(new String[0]));
       
    test.runScript();
   
    List<Tuple> output = getLinesForAlias(test, "data_out", true);
   
    assertEquals(output.size(),1);
    assertEquals(output.get(0).toString(), "(130.0,2280.0,15870.0,50000.0,84130.0,97720.0,99870.0)");
View Full Code Here

   
    String[] expectedOutput = {
        "({((10),(20)),((20),(30)),((30),(40)),((40),(50)),((50),(60))})"
      };
   
    test.runScript();
   
    Iterator<Tuple> actualOutput = test.getAlias("data_out");
   
    assertTuplesMatch(expectedOutput, actualOutput);
  }
View Full Code Here

    String[] expectedOutput = {
        "({((10,100),(20,200)),((20,200),(30,300)),((30,300),(40,400)),((40,400),(50,500)),((50,500),(60,600))})"
      };   
   
   
    test.runScript();
   
    Iterator<Tuple> actualOutput = test.getAlias("data_out");
   
    assertTuplesMatch(expectedOutput, actualOutput);
  }
View Full Code Here

   
    String[] expectedOutput = {
        "({((10),(20)),((10),(30)),((10),(40)),((20),(30)),((20),(40)),((20),(50)),((30),(40)),((30),(50)),((40),(50))})"
      };
   
    test.runScript();
   
    Iterator<Tuple> actualOutput = test.getAlias("data_out");
   
    assertTuplesMatch(expectedOutput, actualOutput);
  }
View Full Code Here

      bufferedWriter.write(sb.toString());
    }

    bufferedWriter.close();

    test.runScript();
    Iterator<Tuple> tuples = test.getAlias("data_grouped3");

    System.out.println("Final node ranks:");
    int nodeCount = 0;
    while (tuples.hasNext())
View Full Code Here

    }
   
    writeLinesToFile("input",
                     input.toArray(new String[0]));
           
    test.runScript();
       
    List<Tuple> tuples = getLinesForAlias(test, "data2", false);
    for (Tuple tuple : tuples)
    {
      Integer randValue = (Integer)tuple.get(1);
View Full Code Here

    writeLinesToFile("input",
                     "ladsljkasdglk",
                     "lkadsljasgjskdjks",
                     "aladlasdgjks");
           
    test.runScript();
       
    assertOutput(test, "data_out",
                 "(d9a82575758bb4978949dc0659205cc6)",
                 "(9ec37f02fae0d8d6a7f4453a62272f1f)",
                 "(cb94139a8b9f3243e68a898ec6bd9b3d)");
View Full Code Here

TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.