Package org.apache.hadoop.mapred

Examples of org.apache.hadoop.mapred.PoolManager.addJob()

2799
2800
2801
2802
2803
2804
2805
2806
2807
2808
2809
        jobTracker);

    // Check that each good pool name is permitted
    for (String goodPoolName : goodPoolNames) {
      job.conf.set(PoolManager.EXPLICIT_POOL_PROPERTY, goodPoolName);
      mgr.addJob(job);
      assertEquals("PoolManager rejected good pool name",
          goodPoolName, mgr.getPoolName(job));
    }

    // Check that each bad pool name is rejected
View Full Code Here
2807
2808
2809
2810
2811
2812
2813
2814
2815
2816
2817
    }

    // Check that each bad pool name is rejected
    for (String badPoolName : badPoolNames) {
      job.conf.set(PoolManager.EXPLICIT_POOL_PROPERTY, badPoolName);
      mgr.addJob(job);
      assertFalse("PoolManager accepted bad pool name",
          badPoolName.equals(mgr.getPoolName(job)));
    }
  }
}
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.