From 62dda10d1678dac8a52feb3fafdb4f549b08c17f Mon Sep 17 00:00:00 2001 From: Raffi Khatchadourian Date: Mon, 20 Aug 2018 23:10:48 -0400 Subject: [PATCH] Apply Optimize Java 8 Stream refactoring. See https://github.com/ponder-lab/Optimize-Java-8-Streams-Refactoring. --- src/main/java/deephacks/streamql/StreamQl.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/deephacks/streamql/StreamQl.java b/src/main/java/deephacks/streamql/StreamQl.java index 486a654..a8f8032 100644 --- a/src/main/java/deephacks/streamql/StreamQl.java +++ b/src/main/java/deephacks/streamql/StreamQl.java @@ -69,13 +69,13 @@ public QueryBuilder visitOrdering(@NotNull OrderingContext ctx) { if (ctx.ordered().ID() == null || ctx.ordered().ID().isEmpty()) { return queryBuilder.setOrdered(); } - List ids = ctx.ordered().ID().stream().map(TerminalNode::getText).collect(Collectors.toList()); + List ids = ctx.ordered().ID().parallelStream().map(TerminalNode::getText).collect(Collectors.toList()); return queryBuilder.setOrdered(ids); } else if (ctx.reversed() != null) { if (ctx.reversed().ID() == null || ctx.reversed().ID().isEmpty()) { return queryBuilder.setReversed(); } - List ids = ctx.reversed().ID().stream().map(TerminalNode::getText).collect(Collectors.toList()); + List ids = ctx.reversed().ID().parallelStream().map(TerminalNode::getText).collect(Collectors.toList()); return queryBuilder.setReversed(ids); } return queryBuilder;