import org.apache.hadoop.mapred.HadoopTestCase; //导入依赖的package包/类
public HiveTestBase() throws IOException {
    super(HadoopTestCase.LOCAL_MR, HadoopTestCase.LOCAL_FS, 1, 1);
    Map<String, String> env = new HashMap<String, String>();
    env.putAll(System.getenv());

    if (System.getenv("HADOOP_HOME") == null) {
        String shome = System.getProperty("user.home");
        if (shome != null) {
            File hadoopHome = new File(new File(shome, "hadoop"), "hadoop-1.2.1_local");
            if (hadoopHome.exists()) {
                env.put("HADOOP_HOME", hadoopHome.getAbsolutePath());
                EnvironmentHack.setEnv(env);
                LOGGER.info(String.format("HADOOP_HOME was set by hiveunit to %1$s.", System.getenv("HADOOP_HOME")));
            }
            File target = new File("target/hadoop-1.2.1");
            if (target.exists()) {
                env.put("HADOOP_HOME", target.getAbsolutePath());
                EnvironmentHack.setEnv(env);
                LOGGER.info(String.format("HADOOP_HOME was set by hiveunit to %1$s.", System.getenv("HADOOP_HOME")));
            }
        } else {
            LOGGER.info(String.format("HADOOP_HOME was found in environment as %1$s. Using that for hiveunit.", System.getenv("HADOOP_HOME")));
        }
        //detect variable or hadoop in path and throw exception here?
    }
}
 

import org.apache.hadoop.mapred.HadoopTestCase; //导入依赖的package包/类
public TestKeyFieldBasedComparator() throws IOException {
  super(HadoopTestCase.LOCAL_MR, HadoopTestCase.LOCAL_FS, 1, 1);
  conf = createJobConf();
  localConf = createJobConf();
  localConf.set(JobContext.MAP_OUTPUT_KEY_FIELD_SEPERATOR, " ");
}
 

import org.apache.hadoop.mapred.HadoopTestCase; //导入依赖的package包/类
public TestChild() throws IOException {
  super(HadoopTestCase.CLUSTER_MR , HadoopTestCase.LOCAL_FS, 2, 2);
}
 

import org.apache.hadoop.mapred.HadoopTestCase; //导入依赖的package包/类
public TestNoJobSetupCleanup() throws IOException {
  super(HadoopTestCase.CLUSTER_MR , HadoopTestCase.LOCAL_FS, 2, 2);
}
 

import org.apache.hadoop.mapred.HadoopTestCase; //导入依赖的package包/类
public TestMultithreadedMapper() throws IOException {
  super(HadoopTestCase.LOCAL_MR, HadoopTestCase.LOCAL_FS, 1, 1);
}
 

import org.apache.hadoop.mapred.HadoopTestCase; //导入依赖的package包/类
public TestMRKeyFieldBasedComparator() throws IOException {
  super(HadoopTestCase.LOCAL_MR, HadoopTestCase.LOCAL_FS, 1, 1);
  conf = createJobConf();
  conf.set(MRJobConfig.MAP_OUTPUT_KEY_FIELD_SEPERATOR, " ");
}
 

import org.apache.hadoop.mapred.HadoopTestCase; //导入依赖的package包/类
public TestMRMultipleOutputs() throws IOException {
  super(HadoopTestCase.LOCAL_MR, HadoopTestCase.LOCAL_FS, 1, 1);
}
 

import org.apache.hadoop.mapred.HadoopTestCase; //导入依赖的package包/类
public TestChainErrors() throws IOException {
  super(HadoopTestCase.LOCAL_MR, HadoopTestCase.LOCAL_FS, 1, 1);
}
 

import org.apache.hadoop.mapred.HadoopTestCase; //导入依赖的package包/类
public TestSingleElementChain() throws IOException {
  super(HadoopTestCase.LOCAL_MR, HadoopTestCase.LOCAL_FS, 1, 1);
}
 

import org.apache.hadoop.mapred.HadoopTestCase; //导入依赖的package包/类
public TestMapReduceChain() throws IOException {
  super(HadoopTestCase.LOCAL_MR, HadoopTestCase.LOCAL_FS, 1, 1);
}
 

import org.apache.hadoop.mapred.HadoopTestCase; //导入依赖的package包/类
public TestMultipleInputs() throws IOException {
  super(HadoopTestCase.LOCAL_MR, HadoopTestCase.LOCAL_FS, 1, 1);
}
 

import org.apache.hadoop.mapred.HadoopTestCase; //导入依赖的package包/类
public TestMapReduceJobControl() throws IOException {
  super(HadoopTestCase.LOCAL_MR , HadoopTestCase.LOCAL_FS, 2, 2);
}
 

import org.apache.hadoop.mapred.HadoopTestCase; //导入依赖的package包/类
public TestTaskContext() throws IOException {
  super(HadoopTestCase.CLUSTER_MR , HadoopTestCase.LOCAL_FS, 1, 1);
}
 

import org.apache.hadoop.mapred.HadoopTestCase; //导入依赖的package包/类
public DataStoreMapReduceTestBase() throws IOException {
  this(HadoopTestCase.CLUSTER_MR, HadoopTestCase.DFS_FS, 2, 2);
}