@@ -0,0 +1,1288 @@
+package org.easybatch.core.writer;%0A%0Aimport org.easybatch.core.record.Record;%0A%0Aimport java.util.List;%0A%0Aimport static java.util.Arrays.asList;%0A%0A/**%0A * Composite writer that delegates record writing to a list of writers.%0A *%0A * @author Mahmoud Ben Hassine (mahmoud.benhassine@icloud.com)%0A */%0Apublic class CompositeRecordWriter implements RecordWriter %7B%0A%0A    private List%3CRecordWriter%3E writers;%0A%0A    /**%0A     * Create a %7B@link CompositeRecordWriter%7D.%0A     *%0A     * @param writers delegates%0A     */%0A    public CompositeRecordWriter(List%3CRecordWriter%3E writers) %7B%0A        this.writers = writers;%0A    %7D%0A%0A    /**%0A     * Create a %7B@link CompositeRecordWriter%7D.%0A     *%0A     * @param writers delegates%0A     */%0A    public CompositeRecordWriter(RecordWriter... writers) %7B%0A        this.writers = asList(writers);%0A    %7D%0A%0A    @Override%0A    public void open() throws Exception %7B%0A        for (RecordWriter writer : writers) %7B%0A            writer.open();%0A        %7D%0A    %7D%0A%0A    @Override%0A    public void writeRecords(List%3CRecord%3E records) throws Exception %7B%0A        for (RecordWriter writer : writers) %7B%0A            writer.writeRecords(records);%0A        %7D%0A    %7D%0A%0A    @Override%0A    public void close() throws Exception %7B%0A        for (RecordWriter writer : writers) %7B%0A            writer.close();%0A        %7D%0A    %7D%0A%7D%0A

add CompositeRecordWriter