[tor-commits] [collector/master] Parallelize two more processing steps.

[karsten at torproject.org]

commit 15db1e2a793ac7e67a1e7aa87c2ea857825a98a2
Author: iwakeh <iwakeh at torproject.org>
Date:   Wed Jan 31 13:31:25 2018 +0000

    Parallelize two more processing steps.
---
 src/main/java/org/torproject/collector/webstats/SanitizeWeblogs.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/main/java/org/torproject/collector/webstats/SanitizeWeblogs.java b/src/main/java/org/torproject/collector/webstats/SanitizeWeblogs.java
index a3d2a7e..4496861 100644
--- a/src/main/java/org/torproject/collector/webstats/SanitizeWeblogs.java
+++ b/src/main/java/org/torproject/collector/webstats/SanitizeWeblogs.java
@@ -113,7 +113,7 @@ public class SanitizeWeblogs extends CollecTorMain {
         LocalDate[] interval = determineInterval(linesByDate.keySet());
         linesByDate.entrySet().stream()
             .filter((entry) -> entry.getKey().isAfter(interval[0])
-              && entry.getKey().isBefore(interval[1]))
+              && entry.getKey().isBefore(interval[1])).parallel()
             .forEach((entry) -> storeSanitized(virtualHost, physicalHost,
               entry.getKey(), entry.getValue()));
       }
@@ -128,7 +128,7 @@ public class SanitizeWeblogs extends CollecTorMain {
         .add(date.format(DateTimeFormatter.BASIC_ISO_DATE)).toString();
     log.debug("Sanitizing {}.", name);
     List<String> retainedLines = lines
-        .stream().map((line) -> sanitize(line, date))
+        .stream().parallel().map((line) -> sanitize(line, date))
         .filter((line) -> line.isPresent()).map((line) -> line.get())
         .collect(Collectors.toList());
     retainedLines.sort(null);