Equivalent of xUnit for testing Pig.
Call {@link PigTest#getCluster()} then construct a test and call an assert method.Have a look to the test of this class for more example.
254255256257258259260261262263264265266267268269
} @Test public void comprehensiveBagSplitAndEnumerate() throws Exception { PigTest test = createPigTest("datafu/bags/comprehensiveBagSplitAndEnumerate.pig"); writeLinesToFile("input", "({(A,1.0),(B,2.0),(C,3.0),(D,4.0),(E,5.0)})"); test.runScript(); assertOutput(test, "data_out", // bag #1 "(A,1.0,1)", "(B,2.0,1)",