Goal is to make writing an output less error prone and more efficient. Here is the sketch
@Processor(name = "BulkOutputDemo") public class BulkProcessor implements Serializable { @AfterGroup public void commit(final Collection<Record> records) { // save records } }