}
@Override
public void map(Object key, Object value, Context context) throws IOException, InterruptedException {
try {
KeyValue input = new KeyValue(key, value);
<BUG>for (KeyValue output : transformExecutor.runOneIteration(input)) {
context.write(output.getKey(), output.getValue());</BUG>
}
} catch (Exception e) {
LOG.error("Exception thrown in BatchDriver Mapper : {}", e);

}
}
@Override
public void map(Object key, Object value, Context context) throws IOException, InterruptedException {
try {
KeyValue input = new KeyValue(key, value);
Iterator<KeyValue> iterator = transformExecutor.runOneIteration(input).getEmittedRecords();
while (iterator.hasNext()) {
KeyValue output = iterator.next();
context.write(output.getKey(), output.getValue());
}
} catch (Exception e) {
LOG.error("Exception thrown in BatchDriver Mapper : {}", e);
