test_class.declarator: mTempDir
test_class.modifier: private
test_class.original_string: private File mTempDir;
test_class.type: File
test_class.var_name: mTempDir
test_class.declarator: mTempPath
test_class.modifier: private
test_class.original_string: private Path mTempPath;
test_class.type: Path
test_class.var_name: mTempPath
test_class.declarator: mTable
test_class.modifier: private
test_class.original_string: private KijiTable mTable;
test_class.type: KijiTable
test_class.var_name: mTable
test_class.file: kiji-mapreduce/src/test/java/org/kiji/mapreduce/input/TestKijiTableMapReduceJobInput.java
test_class.identifier: TestKijiTableMapReduceJobInput
test_class.superclass: extends KijiClientTest
test_case.body: @Test
    public void testConfigure() throws IOException {
      final Job job = new Job();
  
      // Request the latest 3 versions of column 'info:email':
      KijiDataRequestBuilder builder = KijiDataRequest.builder();
      builder.newColumnsDef().withMaxVersions(3).add("info", "email");
      KijiDataRequest dataRequest = builder.build();
  
      // Read from 'here' to 'there':
      final EntityId startRow = HBaseEntityId.fromHBaseRowKey(Bytes.toBytes("here"));
      final EntityId limitRow = HBaseEntityId.fromHBaseRowKey(Bytes.toBytes("there"));
      final KijiRowFilter filter = new StripValueRowFilter();
      final KijiTableMapReduceJobInput.RowOptions rowOptions =
          KijiTableMapReduceJobInput.RowOptions.create(startRow, limitRow, filter);
      final MapReduceJobInput kijiTableJobInput =
          new KijiTableMapReduceJobInput(mTable.getURI(), dataRequest, rowOptions);
      kijiTableJobInput.configure(job);
  
      // Check that the job was configured correctly.
      final Configuration conf = job.getConfiguration();
      assertEquals(
          mTable.getURI(),
          KijiURI.newBuilder(conf.get(KijiConfKeys.KIJI_INPUT_TABLE_URI)).build());
  
      final KijiDataRequest decoded =
          (KijiDataRequest) SerializationUtils.deserialize(
              Base64.decodeBase64(conf.get(KijiConfKeys.KIJI_INPUT_DATA_REQUEST)));
      assertEquals(dataRequest, decoded);
  
      final String confStartRow = Base64.encodeBase64String(startRow.getHBaseRowKey());
      final String confLimitRow = Base64.encodeBase64String(limitRow.getHBaseRowKey());
      assertEquals(confStartRow, conf.get(KijiConfKeys.KIJI_START_ROW_KEY));
      assertEquals(confLimitRow, conf.get(KijiConfKeys.KIJI_LIMIT_ROW_KEY));
  
      assertEquals(filter.toJson().toString(), conf.get(KijiConfKeys.KIJI_ROW_FILTER));
    }
test_case.class_method_signature: TestKijiTableMapReduceJobInput.testConfigure()
test_case.full_signature: @Test public void testConfigure()
test_case.identifier: testConfigure
test_case.invocations: builder add withMaxVersions newColumnsDef build fromHBaseRowKey toBytes fromHBaseRowKey toBytes create getURI configure getConfiguration assertEquals getURI build newBuilder get deserialize decodeBase64 get assertEquals encodeBase64String getHBaseRowKey encodeBase64String getHBaseRowKey assertEquals get assertEquals get assertEquals toString toJson get
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testConfigure()
focal_class.declarator: mInputTableURI
focal_class.modifier: private
focal_class.original_string: private KijiURI mInputTableURI;
focal_class.type: KijiURI
focal_class.var_name: mInputTableURI
focal_class.declarator: mDataRequest
focal_class.modifier: private
focal_class.original_string: private KijiDataRequest mDataRequest;
focal_class.type: KijiDataRequest
focal_class.var_name: mDataRequest
focal_class.declarator: mRowOptions
focal_class.modifier: private
focal_class.original_string: private RowOptions mRowOptions;
focal_class.type: RowOptions
focal_class.var_name: mRowOptions
focal_class.file: kiji-mapreduce/src/main/java/org/kiji/mapreduce/input/KijiTableMapReduceJobInput.java
focal_class.identifier: KijiTableMapReduceJobInput
focal_class.class_method_signature: KijiTableMapReduceJobInput.KijiTableMapReduceJobInput()
focal_class.full_signature:   KijiTableMapReduceJobInput()
focal_class.identifier: KijiTableMapReduceJobInput
focal_class.parameters: ()
focal_class.signature:  KijiTableMapReduceJobInput()
focal_class.class_method_signature: KijiTableMapReduceJobInput.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: KijiTableMapReduceJobInput.KijiTableMapReduceJobInput(
        KijiURI inputTableURI, KijiDataRequest dataRequest, RowOptions rowOptions)
focal_class.full_signature:   KijiTableMapReduceJobInput(
        KijiURI inputTableURI, KijiDataRequest dataRequest, RowOptions rowOptions)
focal_class.identifier: KijiTableMapReduceJobInput
focal_class.parameters: (
        KijiURI inputTableURI, KijiDataRequest dataRequest, RowOptions rowOptions)
focal_class.signature:  KijiTableMapReduceJobInput(
        KijiURI inputTableURI, KijiDataRequest dataRequest, RowOptions rowOptions)
focal_class.class_method_signature: KijiTableMapReduceJobInput.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.class_method_signature: KijiTableMapReduceJobInput.getInputFormatClass()
focal_class.full_signature: @Override protected Class<? extends InputFormat<?, ?>> getInputFormatClass()
focal_class.identifier: getInputFormatClass
focal_class.modifiers: @Override protected
focal_class.parameters: ()
focal_class.return: Class<? extends InputFormat<?, ?>>
focal_class.signature: Class<? extends InputFormat<?, ?>> getInputFormatClass()
focal_class.class_method_signature: KijiTableMapReduceJobInput.getInputTableURI()
focal_class.full_signature: public KijiURI getInputTableURI()
focal_class.identifier: getInputTableURI
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: KijiURI
focal_class.signature: KijiURI getInputTableURI()
focal_class.class_method_signature: KijiTableMapReduceJobInput.getRowOptions()
focal_class.full_signature: public RowOptions getRowOptions()
focal_class.identifier: getRowOptions
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: RowOptions
focal_class.signature: RowOptions getRowOptions()
focal_class.superclass: extends MapReduceJobInput
focal_method.body: @Override
    public void configure(Job job) throws IOException {
      // Configure the input format class.
      super.configure(job);
      KijiTableInputFormat inputFormat =
          KijiTableInputFormat.Factory.get(mInputTableURI).getInputFormat();
      job.setInputFormatClass(inputFormat.getClass());
      KijiTableInputFormat.configureJob(job, mInputTableURI, mDataRequest,
            null != mRowOptions ? mRowOptions.getStartRow() : null,
            null != mRowOptions ? mRowOptions.getLimitRow() : null,
            null != mRowOptions ? mRowOptions.getRowFilter() : null);
    }
focal_method.class_method_signature: KijiTableMapReduceJobInput.configure(Job job)
focal_method.full_signature: @Override public void configure(Job job)
focal_method.identifier: configure
focal_method.invocations: configure getInputFormat get setInputFormatClass getClass configureJob getStartRow getLimitRow getRowFilter
focal_method.modifiers: @Override public
focal_method.parameters: (Job job)
focal_method.return: void
focal_method.signature: void configure(Job job)