TeStereo report
Logger ExecutionTester
@Test public void testPig800Sort() throws Exception {
File fp1=File.createTempFile("test","txt");
PrintStream ps=new PrintStream(new FileOutputStream(fp1));
ps.println("1\t1}");
ps.close();
pig.registerQuery("A = load '" + Util.generateURI(fp1.toString(),pig.getPigContext()) + "'; ");
pig.registerQuery("B = foreach A generate flatten(" + Pig800Udf.class.getName() + "($0));");
pig.registerQuery("C = order B by $0;");
Iterator iter=pig.openIterator("C");
fp1.delete();
}