KijiTableMapReduceJobOutput extends MapReduceJobOutput { @Override public void configure(Job job) throws IOException { super.configure(job); final Configuration conf = job.getConfiguration(); conf.set(KijiConfKeys.KIJI_OUTPUT_TABLE_URI, mTableURI.toString()); job.setNumReduceTasks(getNumReduceTasks()); GenericTableMapReduceUtil.addAllDependencyJars(job); } protected  KijiTableMapReduceJobOutput();  KijiTableMapReduceJobOutput(KijiURI tableURI, int numReduceTasks); @Override void initialize(Map<String, String> params); int getNumReduceTasks(); KijiURI getOutputTableURI(); @Override void configure(Job job);  }
@Test public void testSpecExDisabled() throws Exception { final Kiji kiji = getKiji(); final KijiTableLayout layout = KijiTableLayout.createUpdatedLayout( KijiTableLayouts.getLayout(KijiTableLayouts.SIMPLE), null); kiji.createTable("table", layout); KijiURI tableURI = KijiURI.newBuilder(kiji.getURI()).withTableName("table").build(); final Job job = new Job(); new DirectKijiTableMapReduceJobOutput(tableURI).configure(job); final Configuration conf = job.getConfiguration(); boolean isMapSpecExEnabled = conf.getBoolean("mapred.map.tasks.speculative.execution", true); assertFalse(isMapSpecExEnabled); }