### Question:
JdbcNativeExtractor implements IExtractor<T, S> { @Override public void saveRDD(T t) { try { this.jdbcWriter.save(transformElement(t)); } catch(Exception e) { throw new DeepGenericException("Error while writing row", e); } }  @Override Partition[] getPartitions(S config); @Override boolean hasNext(); @Override T next(); @Override void close(); @Override void initIterator(Partition dp, S config); @Override void saveRDD(T t); @Override List<String> getPreferredLocations(Partition split); @Override void initSave(S config, T first, UpdateQueryBuilder queryBuilder);  }### Answer:
@Test public void testSaveRdd() throws Exception { JdbcNativeExtractor extractor = createJdbcNativeExtractor(); doReturn(new HashMap()).when(extractor).transformElement(any(Object.class)); extractor.saveRDD(new Object()); verify(jdbcWriter, times(1)).save(any(Map.class)); }