import org.apache.pig.pigunit.Cluster; //导入依赖的package包/类
@Ignore("Not ready yet")
@Test
public void testWithMock() throws ParseException, IOException {
    String[] args = {
                    "n=3",
                    "reducers=1",
                    "input=top_queries_input_data.txt",
                    "output=top_3_queries",
    };

    PigServer mockServer = null;
    Cluster mockCluster = null;

    test = new PigTest(PIG_SCRIPT, args, mockServer, mockCluster);

    test.assertOutput(new File("data/top_queries_expected_top_3.txt"));
}
 

import org.apache.pig.pigunit.Cluster; //导入依赖的package包/类
@Ignore("Not ready yet")
@Test
public void testWithMock() throws ParseException, IOException {
  String[] args = {
      "n=3",
      "reducers=1",
      "input=top_queries_input_data.txt",
      "output=top_3_queries",
      };

  PigServer mockServer = null;
  Cluster mockCluster = null;

  test = new PigTest(PIG_SCRIPT, args, mockServer, mockCluster);

  test.assertOutput(new File("data/top_queries_expected_top_3.txt"));
}
 

import org.apache.pig.pigunit.Cluster; //导入依赖的package包/类
public static PigTest createPigTest(String scriptFile, String[] args) throws PigException {
    try {
        PigServer pigServer = new PigServer(ExecType.LOCAL);
        Cluster pigCluster = new Cluster(pigServer.getPigContext());
        return new PigTest(scriptFile, args, pigServer, pigCluster);
    } catch (Exception ex) {
        throw new PigException("Failed to create PigTest instance. ", ex);
    }
}
 

import org.apache.pig.pigunit.Cluster; //导入依赖的package包/类
@Before
public void setupDataFilesForPigServer() throws Exception {
  System.getProperties().setProperty("pigunit.exectype",
      Util.getLocalTestMode().toString());
  Cluster cluster = PigTest.getCluster();
  // Put the data files in target/ so they don't dirty the local git checkout
  cluster.update(
      new Path(getFullPathForTestDataFile("data.txt")),
      new Path("target/data.txt"));
  cluster.update(
      new Path(getFullPathForTestDataFile("data2.txt")),
      new Path("target/data2.txt"));
}