test_class.file: kiji-mapreduce/src/test/java/org/kiji/mapreduce/output/TestKijiTableMapReduceJobOutput.java
test_class.identifier: TestKijiTableMapReduceJobOutput
test_class.superclass: extends KijiClientTest
test_case.body: @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);
    }
test_case.class_method_signature: TestKijiTableMapReduceJobOutput.testSpecExDisabled()
test_case.full_signature: @Test public void testSpecExDisabled()
test_case.identifier: testSpecExDisabled
test_case.invocations: getKiji createUpdatedLayout getLayout createTable build withTableName newBuilder getURI configure getConfiguration getBoolean assertFalse
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testSpecExDisabled()
focal_class.declarator: mTableURI
focal_class.modifier: private
focal_class.original_string: private KijiURI mTableURI;
focal_class.type: KijiURI
focal_class.var_name: mTableURI
focal_class.declarator: mNumReduceTasks
focal_class.modifier: private
focal_class.original_string: private int mNumReduceTasks;
focal_class.type: int
focal_class.var_name: mNumReduceTasks
focal_class.file: kiji-mapreduce/src/main/java/org/kiji/mapreduce/output/KijiTableMapReduceJobOutput.java
focal_class.identifier: KijiTableMapReduceJobOutput
focal_class.class_method_signature: KijiTableMapReduceJobOutput.KijiTableMapReduceJobOutput()
focal_class.full_signature: protected  KijiTableMapReduceJobOutput()
focal_class.identifier: KijiTableMapReduceJobOutput
focal_class.modifiers: protected
focal_class.parameters: ()
focal_class.signature:  KijiTableMapReduceJobOutput()
focal_class.class_method_signature: KijiTableMapReduceJobOutput.initialize(Map<String, String> params)
focal_class.full_signature: @Override public void initialize(Map<String, String> params)
focal_class.identifier: initialize
focal_class.modifiers: @Override public
focal_class.parameters: (Map<String, String> params)
focal_class.return: void
focal_class.signature: void initialize(Map<String, String> params)
focal_class.class_method_signature: KijiTableMapReduceJobOutput.KijiTableMapReduceJobOutput(KijiURI tableURI, int numReduceTasks)
focal_class.full_signature: public  KijiTableMapReduceJobOutput(KijiURI tableURI, int numReduceTasks)
focal_class.identifier: KijiTableMapReduceJobOutput
focal_class.modifiers: public
focal_class.parameters: (KijiURI tableURI, int numReduceTasks)
focal_class.signature:  KijiTableMapReduceJobOutput(KijiURI tableURI, int numReduceTasks)
focal_class.class_method_signature: KijiTableMapReduceJobOutput.getNumReduceTasks()
focal_class.full_signature: public int getNumReduceTasks()
focal_class.identifier: getNumReduceTasks
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: int
focal_class.signature: int getNumReduceTasks()
focal_class.class_method_signature: KijiTableMapReduceJobOutput.getOutputTableURI()
focal_class.full_signature: public KijiURI getOutputTableURI()
focal_class.identifier: getOutputTableURI
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: KijiURI
focal_class.signature: KijiURI getOutputTableURI()
focal_class.class_method_signature: KijiTableMapReduceJobOutput.configure(Job job)
focal_class.full_signature: @Override public void configure(Job job)
focal_class.identifier: configure
focal_class.modifiers: @Override public
focal_class.parameters: (Job job)
focal_class.return: void
focal_class.signature: void configure(Job job)
focal_class.superclass: extends MapReduceJobOutput
focal_method.body: @Override
    public void configure(Job job) throws IOException {
      // sets Hadoop output format according to getOutputFormatClass()
      super.configure(job);
  
      final Configuration conf = job.getConfiguration();
      conf.set(KijiConfKeys.KIJI_OUTPUT_TABLE_URI, mTableURI.toString());
  
      job.setNumReduceTasks(getNumReduceTasks());
  
      // Adds HBase dependency jars to the distributed cache so they appear on the task classpath:
      GenericTableMapReduceUtil.addAllDependencyJars(job);
    }
focal_method.class_method_signature: KijiTableMapReduceJobOutput.configure(Job job)
focal_method.full_signature: @Override public void configure(Job job)
focal_method.identifier: configure
focal_method.invocations: configure getConfiguration set toString setNumReduceTasks getNumReduceTasks addAllDependencyJars
focal_method.modifiers: @Override public
focal_method.parameters: (Job job)
focal_method.return: void
focal_method.signature: void configure(Job job)