@Test public void testCleanup() throws Exception { Configuration conf = new Configuration(); conf.set(NAMED_OUTPUT_META, "meta"); conf.set(NAMED_OUTPUT_FAULT, "fault"); conf.set(NAMED_OUTPUT_FAULT, "fault"); doReturn(conf).when(context).getConfiguration(); doReturn(invalidPdfCounter).when(context).getCounter(INVALID_PDF_HEADER); mapper.setup(context); mapper.cleanup(context); verify(multipleOutputs, times(1)).close(); }
@Override public void cleanup(Context context) throws IOException, InterruptedException { mos.close(); }
MetadataExtractorMapper extends Mapper<AvroKey<DocumentContent>, NullWritable, NullWritable, NullWritable> { @Override public void cleanup(Context context) throws IOException, InterruptedException { mos.close(); } }
MetadataExtractorMapper extends Mapper<AvroKey<DocumentContent>, NullWritable, NullWritable, NullWritable> { @Override public void cleanup(Context context) throws IOException, InterruptedException { mos.close(); }  }
MetadataExtractorMapper extends Mapper<AvroKey<DocumentContent>, NullWritable, NullWritable, NullWritable> { @Override public void cleanup(Context context) throws IOException, InterruptedException { mos.close(); }  @Override void cleanup(Context context); @Override void map(AvroKey<DocumentContent> key, NullWritable ignore, Context context); }
MetadataExtractorMapper extends Mapper<AvroKey<DocumentContent>, NullWritable, NullWritable, NullWritable> { @Override public void cleanup(Context context) throws IOException, InterruptedException { mos.close(); }  @Override void cleanup(Context context); @Override void map(AvroKey<DocumentContent> key, NullWritable ignore, Context context); static final String NAMED_OUTPUT_META; static final String NAMED_OUTPUT_FAULT; static final String EXCLUDED_IDS; static final String LOG_FAULT_PROCESSING_TIME_THRESHOLD_SECS; static final String INTERRUPT_PROCESSING_TIME_THRESHOLD_SECS; static final String FAULT_CODE_PROCESSING_TIME_THRESHOLD_EXCEEDED; static final String FAULT_SUPPLEMENTARY_DATA_PROCESSING_TIME; }