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;