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/master Commit: ea58cc8ee4dfd32ea3ef1d8a7e267a3c14686ad6 Parents: a48878f Author: Eric C. Newton <eric.new...@gmail.com> Authored: Tue Nov 4 12:02:08 2014 -0500 Committer: Eric C. Newton <eric.new...@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),
