diff --git a/processing/src/main/java/edu/harvard/hms/dbmi/avillach/hpds/processing/io/PfbWriter.java b/processing/src/main/java/edu/harvard/hms/dbmi/avillach/hpds/processing/io/PfbWriter.java index 2d098a7a..692c03eb 100644 --- a/processing/src/main/java/edu/harvard/hms/dbmi/avillach/hpds/processing/io/PfbWriter.java +++ b/processing/src/main/java/edu/harvard/hms/dbmi/avillach/hpds/processing/io/PfbWriter.java @@ -7,6 +7,8 @@ import org.apache.avro.generic.GenericDatumWriter; import org.apache.avro.generic.GenericRecord; import org.apache.avro.io.DatumWriter; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import java.io.File; import java.io.IOException; @@ -16,6 +18,8 @@ public class PfbWriter implements ResultWriter { + private Logger log = LoggerFactory.getLogger(PfbWriter.class); + private final Schema metadataSchema; private final Schema nodeSchema; private SchemaBuilder.FieldAssembler entityFieldAssembler; @@ -65,6 +69,7 @@ public void writeHeader(String[] data) { DatumWriter datumWriter = new GenericDatumWriter(entitySchema); dataFileWriter = new DataFileWriter(datumWriter); try { + log.info("Creating temp avro file at " + file.getAbsoluteFile()); dataFileWriter.create(entitySchema, file); } catch (IOException e) { throw new UncheckedIOException(e);