Use stopwatch for ingestjob to make timing a bit cleaner (#2517)

* Use stopwatch for ingestjob to make timing a bit cleaner

* Update timer name and print pretty summary

warehouse/ingest-core/src/main/java/datawave/ingest/mapreduce/job/IngestJob.java

@@ -79,6 +79,7 @@
 import org.apache.log4j.Level;
 import org.apache.log4j.Logger;
 import org.apache.log4j.PatternLayout;
+import org.springframework.util.StopWatch;
 
 import datawave.ingest.config.TableConfigCache;
 import datawave.ingest.data.Type;
@@ -249,7 +250,11 @@ protected void printUsage() {
 
     @Override
     public int run(String[] args) throws Exception {
-        long setupStart = System.currentTimeMillis();
+
+        long start = System.currentTimeMillis();
+
+        StopWatch sw = new StopWatch("Ingest Job");
+        sw.start("local init");
 
         Logger.getLogger(TypeRegistry.class).setLevel(Level.ALL);
 
@@ -365,8 +370,9 @@ public int run(String[] args) throws Exception {
         URL.setURLStreamHandlerFactory(new FsUrlStreamHandlerFactory(conf));
 
         startDaemonProcesses(conf);
-        long start = System.currentTimeMillis();
-        log.info("JOB SETUP TIME: " + (start - setupStart));
+        sw.stop();
+        log.info(formatTaskInfo(sw.getLastTaskInfo()));
+        sw.start("AM Init");
 
         job.submit();
         JobID jobID = job.getJobID();
@@ -420,12 +426,18 @@ public int run(String[] args) throws Exception {
                 }
             }
         }
-        long setupStop = System.currentTimeMillis();
-        log.info("JOB SETUP TIME: " + (setupStop - setupStart) + "ms");
+        sw.stop();
+        log.info(formatTaskInfo(sw.getLastTaskInfo()));
 
+        sw.start("MR Job");
         job.waitForCompletion(true);
+        sw.stop();
+
         long stop = System.currentTimeMillis();
 
+        log.info(formatTaskInfo(sw.getLastTaskInfo()));
+        log.info(sw.prettyPrint());
+
         // output the counters to the log
         Counters counters = job.getCounters();
         try (JobClient jobClient = new JobClient((org.apache.hadoop.mapred.JobConf) job.getConfiguration())) {
@@ -533,6 +545,10 @@ public int run(String[] args) throws Exception {
         return 0;
     }
 
+    private String formatTaskInfo(StopWatch.TaskInfo taskInfo) {
+        return "Timing - " + taskInfo.getTaskName() + ": " + taskInfo.getTimeSeconds() + " s";
+    }
+
     private void setupHandlers(Configuration conf) {
         // default to all types
         Collection<Type> types = TypeRegistry.getTypes();