Java 类org.apache.hadoop.mapred.gridmix.SubmitterUserResolver 实例源码

项目：hadoop-2.6.0-cdh5.4.3 文件：TestGridMixDataGeneration.java

/**
 * Generate the data in a STRESS submission policy with SubmitterUserResolver 
 * mode and verify whether the generated data matches with given 
 * input size or not.
 * @throws IOException
 */
@Test
public void testGenerateDataWithSTRESSSubmission() throws Exception {
  conf = rtClient.getDaemonConf();
  final long inputSize = cSize * 128;
  String [] runtimeValues ={"LOADJOB",
     SubmitterUserResolver.class.getName(),
     "STRESS",
     inputSize+"m",
     "file:///dev/null"}; 

  int exitCode = UtilsForGridmix.runGridmixJob(gridmixDir, 
    conf,GridMixRunMode.DATA_GENERATION, runtimeValues);
  Assert.assertEquals("Data generation has failed.", 0 , exitCode);
  checkGeneratedDataAndJobStatus(inputSize);
}

项目：hadoop-on-lustre 文件：TestGridMixDataGeneration.java

/**
 * Generate the data in a STRESS submission policy with SubmitterUserResolver 
 * mode and verify whether the generated data matches with given 
 * input size or not.
 * @throws IOException
 */
@Test
public void testGenerateDataWithSTRESSSubmission() throws Exception {
  conf = rtClient.getDaemonConf();
  final long inputSize = cSize * 128;
  String [] runtimeValues ={"LOADJOB",
     SubmitterUserResolver.class.getName(),
     "STRESS",
     inputSize+"m",
     "file:///dev/null"}; 

  int exitCode = UtilsForGridmix.runGridmixJob(gridmixDir, 
    conf,GridMixRunMode.DATA_GENERATION, runtimeValues);
  Assert.assertEquals("Data generation has failed.", 0 , exitCode);
  checkGeneratedDataAndJobStatus(inputSize);
}

项目：hanoi-hadoop-2.0.0-cdh 文件：TestGridMixDataGeneration.java

/**
 * Generate the data in a STRESS submission policy with SubmitterUserResolver 
 * mode and verify whether the generated data matches with given 
 * input size or not.
 * @throws IOException
 */
@Test
public void testGenerateDataWithSTRESSSubmission() throws Exception {
  conf = rtClient.getDaemonConf();
  final long inputSize = cSize * 128;
  String [] runtimeValues ={"LOADJOB",
     SubmitterUserResolver.class.getName(),
     "STRESS",
     inputSize+"m",
     "file:///dev/null"}; 

  int exitCode = UtilsForGridmix.runGridmixJob(gridmixDir, 
    conf,GridMixRunMode.DATA_GENERATION, runtimeValues);
  Assert.assertEquals("Data generation has failed.", 0 , exitCode);
  checkGeneratedDataAndJobStatus(inputSize);
}

项目：mapreduce-fork 文件：TestGridMixDataGeneration.java

/**
 * Generate the data in a STRESS submission policy with SubmitterUserResolver 
 * mode and verify whether the generated data matches with given 
 * input size or not.
 * @throws IOException
 */
@Test
public void testGenerateDataWithSTRESSSubmission() throws Exception {
  conf = rtClient.getDaemonConf();
  final long inputSizeInMB = cSize * 128;
  String [] runtimeValues = {"LOADJOB",
                             SubmitterUserResolver.class.getName(),
                             "STRESS",
                             inputSizeInMB + "m",
                             "file:///dev/null"};

  String [] otherArgs = {
      "-D", GridMixConfig.GRIDMIX_DISTCACHE_ENABLE + "=false", 
      "-D", GridMixConfig.GRIDMIX_COMPRESSION_ENABLE + "=false"
  };
  int exitCode = 
      UtilsForGridmix.runGridmixJob(gridmixDir, conf, 
          GridMixRunMode.DATA_GENERATION.getValue(), 
          runtimeValues, otherArgs);
  Assert.assertEquals("Data generation has failed.", 0 , exitCode);
  checkGeneratedDataAndJobStatus(inputSizeInMB);
}

项目：hortonworks-extension 文件：TestGridMixDataGeneration.java

/**
 * Generate the data in a STRESS submission policy with SubmitterUserResolver 
 * mode and verify whether the generated data matches with given 
 * input size or not.
 * @throws IOException
 */
@Test
public void testGenerateDataWithSTRESSSubmission() throws Exception {
  conf = rtClient.getDaemonConf();
  final long inputSize = cSize * 128;
  String [] runtimeValues ={"LOADJOB",
     SubmitterUserResolver.class.getName(),
     "STRESS",
     inputSize+"m",
     "file:///dev/null"}; 

  int exitCode = UtilsForGridmix.runGridmixJob(gridmixDir, 
    conf,GridMixRunMode.DATA_GENERATION, runtimeValues);
  Assert.assertEquals("Data generation has failed.", 0 , exitCode);
  checkGeneratedDataAndJobStatus(inputSize);
}

项目：hortonworks-extension 文件：TestGridMixDataGeneration.java

/**
 * Generate the data in a STRESS submission policy with SubmitterUserResolver 
 * mode and verify whether the generated data matches with given 
 * input size or not.
 * @throws IOException
 */
@Test
public void testGenerateDataWithSTRESSSubmission() throws Exception {
  conf = rtClient.getDaemonConf();
  final long inputSize = cSize * 128;
  String [] runtimeValues ={"LOADJOB",
     SubmitterUserResolver.class.getName(),
     "STRESS",
     inputSize+"m",
     "file:///dev/null"}; 

  int exitCode = UtilsForGridmix.runGridmixJob(gridmixDir, 
    conf,GridMixRunMode.DATA_GENERATION, runtimeValues);
  Assert.assertEquals("Data generation has failed.", 0 , exitCode);
  checkGeneratedDataAndJobStatus(inputSize);
}