ALS-6511: Add log message for avro file locaton

hms-dbmi · Jul 22, 2024 · bd3a945 · bd3a945
1 parent d149826
commit bd3a945
Showing 1 changed file with 5 additions and 0 deletions.
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
@@ -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<Schema> entityFieldAssembler;
@@ -65,6 +69,7 @@ public void writeHeader(String[] data) {
         DatumWriter<GenericRecord> datumWriter = new GenericDatumWriter<GenericRecord>(entitySchema);
         dataFileWriter = new DataFileWriter<GenericRecord>(datumWriter);
         try {
+            log.info("Creating temp avro file at " + file.getAbsoluteFile());
             dataFileWriter.create(entitySchema, file);
         } catch (IOException e) {
             throw new UncheckedIOException(e);