Changeset 30986

Timestamp:

2016-10-29T16:57:17+13:00 (6 years ago)

Author:

davidb

Message:

Debugging for double accumulator added

File:

• other-projects/hathitrust/solr-extracted-features/trunk/src/main/java/org/hathitrust/PrepareForIngest.java (modified) (2 diffs)

other-projects/hathitrust/solr-extracted-features/trunk/src/main/java/org/hathitrust/PrepareForIngest.java

@@ -50 +50 @@
         double per_vol = 100.0/(double)num_volumes;
         
-        DoubleAccumulator progress_accum = jsc.sc().doubleAccumulator("ProgressPercent");
+        DoubleAccumulator progress_accum = jsc.sc().doubleAccumulator("Progress Percent");
         
         PagedJSON paged_json = new PagedJSON(_input_dir,_solr_url,_output_dir,_verbosity, progress_accum,per_vol);
@@ -58 +58 @@
 
     
+
+        System.out.println("");
+        System.out.println("############");
+        System.out.println("# Progress Accumulator: " + progress_accum.value());
+        System.out.println("############");
+        System.out.println("");
+
+        
         //long num_ids = json_ids.count();
         long num_ids = num_volumes;