String status = "Consolidating " + sources.size() + " files into " + tmpFile.toString();
LOG.info(status);
rprtr.setStatus(status);
RecordStreamFactory fact = args.streams;
fs.mkdirs(finalFile.getParent());
RecordOutputStream os = fact.getOutputStream(fs, tmpFile);
for(Path i: sources) {
LOG.info("Opening " + i.toString() + " for consolidation");
RecordInputStream is = fact.getInputStream(fs, i);
byte[] record;
while((record = is.readRawRecord()) != null) {
os.writeRaw(record);
}
is.close();