accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From e..@apache.org
Subject git commit: ACCUMULO-3244 add filename to bulk import report
Date Tue, 04 Nov 2014 17:07:06 GMT
Repository: accumulo
Updated Branches:
  refs/heads/1.6 a48878f34 -> ea58cc8ee


ACCUMULO-3244 add filename to bulk import report


Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/ea58cc8e
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/ea58cc8e
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/ea58cc8e

Branch: refs/heads/1.6
Commit: ea58cc8ee4dfd32ea3ef1d8a7e267a3c14686ad6
Parents: a48878f
Author: Eric C. Newton <eric.newton@gmail.com>
Authored: Tue Nov 4 12:02:08 2014 -0500
Committer: Eric C. Newton <eric.newton@gmail.com>
Committed: Tue Nov 4 12:02:08 2014 -0500

----------------------------------------------------------------------
 .../org/apache/accumulo/server/client/BulkImporter.java   | 10 ++++++++--
 1 file changed, 8 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/accumulo/blob/ea58cc8e/server/base/src/main/java/org/apache/accumulo/server/client/BulkImporter.java
----------------------------------------------------------------------
diff --git a/server/base/src/main/java/org/apache/accumulo/server/client/BulkImporter.java
b/server/base/src/main/java/org/apache/accumulo/server/client/BulkImporter.java
index 27ab078..99126d8 100644
--- a/server/base/src/main/java/org/apache/accumulo/server/client/BulkImporter.java
+++ b/server/base/src/main/java/org/apache/accumulo/server/client/BulkImporter.java
@@ -261,7 +261,7 @@ public class BulkImporter {
       assignmentStats.unrecoveredMapFiles(failedFailures);
       
       timer.stop(Timers.TOTAL);
-      printReport();
+      printReport(paths);
       return assignmentStats;
     } finally {
       if (client != null)
@@ -270,7 +270,7 @@ public class BulkImporter {
     }
   }
   
-  private void printReport() {
+  private void printReport(Set<Path> paths) {
     long totalTime = 0;
     for (Timers t : Timers.values()) {
       if (t == Timers.TOTAL)
@@ -278,8 +278,14 @@ public class BulkImporter {
       
       totalTime += timer.get(t);
     }
+    List<String> files = new ArrayList<String>();
+    for (Path path : paths) {
+      files.add(path.getName());
+    }
+    Collections.sort(files);
     
     log.debug("BULK IMPORT TIMING STATISTICS");
+    log.debug("Files: " + files);
     log.debug(String.format("Examine map files    : %,10.2f secs %6.2f%s", timer.getSecs(Timers.EXAMINE_MAP_FILES),
100.0 * timer.get(Timers.EXAMINE_MAP_FILES)
         / timer.get(Timers.TOTAL), "%"));
     log.debug(String.format("Query %-14s : %,10.2f secs %6.2f%s", MetadataTable.NAME, timer.getSecs(Timers.QUERY_METADATA),


Mime
View raw message