@Test
    @SuppressWarnings(value = "unchecked")
    public void testJob() throws IOException {
        System.setProperty("HADOOP_USER_NAME", "hduser");
        Injector injector = Guice.createInjector(new Context());
        HadoopContext hadoopContext = injector.getInstance(HadoopContext.class);
        HDFS hdfs = injector.getInstance(HDFS.class);
        JobConf conf = this.jobConf(hadoopContext);
        hdfs.init();
        hdfs.deleteDirectory("/output");
        FileInputFormat.setInputPaths(conf, new Path("input"));
        FileOutputFormat.setOutputPath(conf, new Path("output"));
        JobClient.runJob(conf);
    }