diff --git a/avro-builder/builder-spi/src/main/java/com/linkedin/avroutil1/builder/util/StreamUtil.java b/avro-builder/builder-spi/src/main/java/com/linkedin/avroutil1/builder/util/StreamUtil.java index 7825f5fe..3d5b047e 100644 --- a/avro-builder/builder-spi/src/main/java/com/linkedin/avroutil1/builder/util/StreamUtil.java +++ b/avro-builder/builder-spi/src/main/java/com/linkedin/avroutil1/builder/util/StreamUtil.java @@ -19,8 +19,6 @@ import java.util.stream.IntStream; import java.util.stream.Stream; -import static java.util.stream.Collectors.*; - /** * Utilities for dealing with java streams. @@ -88,7 +86,8 @@ private StreamUtil() { } final int batchCount = (list.size() - 1) / batchSize; - final Function<List<T>, List<R>> batchingMapper = batch -> batch.stream().map(mapper).collect(toList()); + final Function<List<T>, List<R>> batchingMapper = + batch -> batch.stream().map(mapper).collect(Collectors.toList()); List<List<T>> sublists = IntStream.rangeClosed(0, batchCount).mapToObj(batch -> { int startIndex = batch * batchSize; int endIndex = (batch == batchCount) ? list.size() : (batch + 1) * batchSize;