Method setUp

test/org/apache/pig/test/TestLargeFile.java:59–90

()

    String fileName, tmpFile1;

    @Before
    public void setUp() throws Exception{

        System.out.println("Generating test data...");
        System.out.println("Default block size = " + defaultBlockSize);
        System.out.println("Total no. of iterations to run for the test data = " + total);

        datFile = File.createTempFile("StoreTest", ".dat");

        FileOutputStream dat = new FileOutputStream(datFile);

        Random rand = new Random();

        for(int i = 0; i < max_rand; i++) {
            COUNT[i] = 0;
        }

        for(long i = 0; i < total; i++) {
            Integer x = new Integer(rand.nextInt(max_rand));
            COUNT[x.intValue()]++;
            dat.write((x.toString() + "\n").getBytes());
        }

        dat.close();

        pig = new PigServer(ExecType.MAPREDUCE, cluster.getProperties());

        fileName = "'" + FileLocalizer.hadoopify(datFile.toString(), pig.getPigContext()) + "'";
        tmpFile1 = "'" + FileLocalizer.getTemporaryPath(pig.getPigContext()).toString() + "'";

        datFile.delete();
    }

    @After
    public void tearDown() throws Exception {