BatchingSpliterator.java

1 
package com.pivovarit.collectors;
2
3 
import java.util.ArrayList;
4 
import java.util.List;
5 
import java.util.Spliterator;
6 
import java.util.function.Consumer;
7 
import java.util.function.Function;
8 
import java.util.stream.Stream;
9
10 
import static java.util.stream.Stream.empty;
11 
import static java.util.stream.Stream.of;
12 
import static java.util.stream.StreamSupport.stream;
13
14 
/**
15 
 * @author Grzegorz Piwowarek
16 
 */
17 
final class BatchingSpliterator<T> implements Spliterator<List<T>> {
18
19 
    private final List<T> source;
20 
    private int maxChunks;
21
22 
    private int chunks;
23 
    private int chunkSize;
24 
    private int consumed;
25
26 
    BatchingSpliterator(List<T> list, int batches) {
27 2 1. <init> : changed conditional boundary → SURVIVED
2. <init> : negated conditional → KILLED
 
        if (batches < 1) {
28 
            throw new IllegalArgumentException("batches can't be lower than one");
29 
        }
30 
        source = list;
31 
        chunks = batches;
32 
        maxChunks = Math.min(list.size(), batches);
33 1 1. <init> : Replaced double division with multiplication → KILLED
 
        chunkSize = (int) Math.ceil(((double) source.size()) / batches);
34 
    }
35
36 
    static <T> Stream<List<T>> partitioned(List<T> list, int numberOfParts) {
37 
        int size = list.size();
38
39 1 1. partitioned : negated conditional → KILLED
 
        if (size == 0) {
40 
            return empty();
41 1 1. partitioned : negated conditional → KILLED
 
        } else if (numberOfParts == 1) {
42 1 1. partitioned : replaced return value with Stream.empty for com/pivovarit/collectors/BatchingSpliterator::partitioned → KILLED
 
            return of(list);
43 2 1. partitioned : changed conditional boundary → SURVIVED
2. partitioned : negated conditional → KILLED
 
        } else if (size <= numberOfParts) {
44 1 1. partitioned : replaced return value with Stream.empty for com/pivovarit/collectors/BatchingSpliterator::partitioned → KILLED
 
            return asSingletonListStream(list);
45 
        } else {
46 1 1. partitioned : replaced return value with Stream.empty for com/pivovarit/collectors/BatchingSpliterator::partitioned → KILLED
 
            return stream(new BatchingSpliterator<>(list, numberOfParts), false);
47 
        }
48 
    }
49
50 
    private static <T> Stream<List<T>> asSingletonListStream(List<T> list) {
51 
        Stream.Builder<List<T>> acc = Stream.builder();
52 
        for (T t : list) {
53 
            acc.add(List.of(t));
54 
        }
55 1 1. asSingletonListStream : replaced return value with Stream.empty for com/pivovarit/collectors/BatchingSpliterator::asSingletonListStream → KILLED
 
        return acc.build();
56 
    }
57
58 
    static <T, R> Function<List<T>, List<R>> batching(Function<? super T, R> mapper) {
59 1 1. batching : replaced return value with null for com/pivovarit/collectors/BatchingSpliterator::batching → KILLED
 
        return batch -> {
60 
            List<R> list = new ArrayList<>(batch.size());
61 
            for (T t : batch) {
62 
                list.add(mapper.apply(t));
63 
            }
64 1 1. lambda$batching$0 : replaced return value with Collections.emptyList for com/pivovarit/collectors/BatchingSpliterator::lambda$batching$0 → KILLED
 
            return list;
65 
        };
66 
    }
67
68 
    @Override
69 
    public boolean tryAdvance(Consumer<? super List<T>> action) {
70 3 1. tryAdvance : changed conditional boundary → KILLED
2. tryAdvance : negated conditional → KILLED
3. tryAdvance : negated conditional → KILLED
 
        if (consumed < source.size() && chunks != 0) {
71 1 1. tryAdvance : Replaced integer addition with subtraction → KILLED
 
            int end = Math.min(source.size(), consumed + chunkSize);
72 
            List<T> batch = source.subList(consumed, end);
73 1 1. tryAdvance : Replaced integer addition with subtraction → KILLED
 
            consumed += batch.size();
74 3 1. tryAdvance : Replaced integer subtraction with addition → KILLED
2. tryAdvance : Replaced double division with multiplication → KILLED
3. tryAdvance : Replaced integer subtraction with addition → KILLED
 
            chunkSize = (int) Math.ceil(((double) (source.size() - consumed)) / --chunks);
75 1 1. tryAdvance : removed call to java/util/function/Consumer::accept → KILLED
 
            action.accept(batch);
76 1 1. tryAdvance : replaced boolean return with false for com/pivovarit/collectors/BatchingSpliterator::tryAdvance → KILLED
 
            return true;
77 
        } else {
78 1 1. tryAdvance : replaced boolean return with true for com/pivovarit/collectors/BatchingSpliterator::tryAdvance → TIMED_OUT
 
            return false;
79 
        }
80 
    }
81
82 
    @Override
83 
    public Spliterator<List<T>> trySplit() {
84 1 1. trySplit : Replaced integer subtraction with addition → SURVIVED
 
        int remaining = source.size() - consumed;
85 4 1. trySplit : changed conditional boundary → SURVIVED
2. trySplit : changed conditional boundary → KILLED
3. trySplit : negated conditional → KILLED
4. trySplit : negated conditional → KILLED
 
        if (remaining <= chunkSize || chunks <= 1) {
86 
            return null;
87 
        }
88
89 1 1. trySplit : Replaced integer division with multiplication → KILLED
 
        int midChunks = chunks / 2;
90 1 1. trySplit : Replaced integer multiplication with division → KILLED
 
        int midSize = midChunks * chunkSize;
91
92 1 1. trySplit : Replaced integer addition with subtraction → KILLED
 
        var subList = source.subList(consumed, consumed + midSize);
93 
        var split = new BatchingSpliterator<>(subList, midChunks);
94
95 1 1. trySplit : Replaced integer addition with subtraction → KILLED
 
        consumed += midSize;
96 1 1. trySplit : Replaced integer subtraction with addition → KILLED
 
        chunks -= midChunks;
97 1 1. trySplit : Replaced integer subtraction with addition → KILLED
 
        maxChunks -= midChunks;
98 2 1. trySplit : Replaced integer subtraction with addition → KILLED
2. trySplit : Replaced double division with multiplication → KILLED
 
        chunkSize = (int) Math.ceil(((double) (source.size() - consumed)) / chunks);
99
100 1 1. trySplit : replaced return value with null for com/pivovarit/collectors/BatchingSpliterator::trySplit → KILLED
 
        return split;
101 
    }
102
103 
    @Override
104 
    public long estimateSize() {
105 1 1. estimateSize : replaced long return with 0 for com/pivovarit/collectors/BatchingSpliterator::estimateSize → KILLED
 
        return maxChunks;
106 
    }
107
108 
    @Override
109 
    public int characteristics() {
110 1 1. characteristics : replaced int return with 0 for com/pivovarit/collectors/BatchingSpliterator::characteristics → KILLED
 
        return IMMUTABLE | ORDERED | SIZED | SUBSIZED;
111 
    }
112 
}

Mutations

27

1.1
Location : <init>
Killed by : none changed conditional boundary → SURVIVED Covering tests

2.2
Location : <init>
Killed by : com.pivovarit.collectors.BatchingSpliteratorTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.BatchingSpliteratorTest]/[method:shouldReportCorrectSizeWhenMultipleBatches()] negated conditional → KILLED

33

1.1
Location : <init>
Killed by : com.pivovarit.collectors.BatchingSpliteratorTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.BatchingSpliteratorTest]/[method:shouldHandleExactDivisibility()] Replaced double division with multiplication → KILLED

39

1.1
Location : partitioned
Killed by : com.pivovarit.collectors.BatchingSpliteratorTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.BatchingSpliteratorTest]/[method:shouldReturnSameListWhenBatchesIsOne()] negated conditional → KILLED

41

1.1
Location : partitioned
Killed by : com.pivovarit.collectors.BatchingSpliteratorTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.BatchingSpliteratorTest]/[method:shouldReportCorrectSizeWhenMultipleBatches()] negated conditional → KILLED

42

1.1
Location : partitioned
Killed by : com.pivovarit.collectors.BatchingSpliteratorTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.BatchingSpliteratorTest]/[method:shouldReturnSameListWhenBatchesIsOne()] replaced return value with Stream.empty for com/pivovarit/collectors/BatchingSpliterator::partitioned → KILLED

43

1.1
Location : partitioned
Killed by : com.pivovarit.collectors.BatchingSpliteratorTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.BatchingSpliteratorTest]/[method:shouldReportCorrectSizeWhenMultipleBatches()] negated conditional → KILLED

2.2
Location : partitioned
Killed by : none changed conditional boundary → SURVIVED Covering tests

44

1.1
Location : partitioned
Killed by : com.pivovarit.collectors.BatchingSpliteratorTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.BatchingSpliteratorTest]/[method:shouldPartitionToSingletonsWhenSizeLessThanBatches()] replaced return value with Stream.empty for com/pivovarit/collectors/BatchingSpliterator::partitioned → KILLED

46

1.1
Location : partitioned
Killed by : com.pivovarit.collectors.BatchingSpliteratorTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.BatchingSpliteratorTest]/[method:shouldReportCorrectSizeWhenMultipleBatches()] replaced return value with Stream.empty for com/pivovarit/collectors/BatchingSpliterator::partitioned → KILLED

55

1.1
Location : asSingletonListStream
Killed by : com.pivovarit.collectors.BatchingSpliteratorTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.BatchingSpliteratorTest]/[method:shouldPartitionToSingletonsWhenSizeLessThanBatches()] replaced return value with Stream.empty for com/pivovarit/collectors/BatchingSpliterator::asSingletonListStream → KILLED

59

1.1
Location : batching
Killed by : com.pivovarit.collectors.test.BasicParallelismTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.test.BasicParallelismTest]/[test-factory:shouldProcessAllElementsWithMaxParallelism()]/[dynamic-test:#22] replaced return value with null for com/pivovarit/collectors/BatchingSpliterator::batching → KILLED

64

1.1
Location : lambda$batching$0
Killed by : com.pivovarit.collectors.test.BasicParallelismTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.test.BasicParallelismTest]/[test-factory:shouldProcessAllElementsWithMaxParallelism()]/[dynamic-test:#22] replaced return value with Collections.emptyList for com/pivovarit/collectors/BatchingSpliterator::lambda$batching$0 → KILLED

70

1.1
Location : tryAdvance
Killed by : com.pivovarit.collectors.BatchingSpliteratorTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.BatchingSpliteratorTest]/[method:shouldHandleEmptyList()] changed conditional boundary → KILLED

2.2
Location : tryAdvance
Killed by : com.pivovarit.collectors.BatchingSpliteratorTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.BatchingSpliteratorTest]/[method:shouldHandleEmptyList()] negated conditional → KILLED

3.3
Location : tryAdvance
Killed by : com.pivovarit.collectors.BatchingSpliteratorTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.BatchingSpliteratorTest]/[method:shouldHandleExactDivisibility()] negated conditional → KILLED

71

1.1
Location : tryAdvance
Killed by : com.pivovarit.collectors.BatchingSpliteratorTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.BatchingSpliteratorTest]/[method:shouldHandleExactDivisibility()] Replaced integer addition with subtraction → KILLED

73

1.1
Location : tryAdvance
Killed by : com.pivovarit.collectors.BatchingSpliteratorTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.BatchingSpliteratorTest]/[method:shouldHandleExactDivisibility()] Replaced integer addition with subtraction → KILLED

74

1.1
Location : tryAdvance
Killed by : com.pivovarit.collectors.BatchingSpliteratorTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.BatchingSpliteratorTest]/[method:shouldNotExceedBoundsForUnevenSplit()] Replaced integer subtraction with addition → KILLED

2.2
Location : tryAdvance
Killed by : com.pivovarit.collectors.BatchingSpliteratorTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.BatchingSpliteratorTest]/[method:shouldNotExceedBoundsForUnevenSplit()] Replaced double division with multiplication → KILLED

3.3
Location : tryAdvance
Killed by : com.pivovarit.collectors.BatchingSpliteratorTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.BatchingSpliteratorTest]/[method:shouldHandleExactDivisibility()] Replaced integer subtraction with addition → KILLED

75

1.1
Location : tryAdvance
Killed by : com.pivovarit.collectors.BatchingSpliteratorTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.BatchingSpliteratorTest]/[method:shouldHandleExactDivisibility()] removed call to java/util/function/Consumer::accept → KILLED

76

1.1
Location : tryAdvance
Killed by : com.pivovarit.collectors.BatchingSpliteratorTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.BatchingSpliteratorTest]/[method:shouldHandleExactDivisibility()] replaced boolean return with false for com/pivovarit/collectors/BatchingSpliterator::tryAdvance → KILLED

78

1.1
Location : tryAdvance
Killed by : none replaced boolean return with true for com/pivovarit/collectors/BatchingSpliterator::tryAdvance → TIMED_OUT

84

1.1
Location : trySplit
Killed by : none Replaced integer subtraction with addition → SURVIVED Covering tests

85

1.1
Location : trySplit
Killed by : none changed conditional boundary → SURVIVED Covering tests

2.2
Location : trySplit
Killed by : com.pivovarit.collectors.BatchingSpliteratorTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.BatchingSpliteratorTest]/[method:shouldHandleEmptyList()] changed conditional boundary → KILLED

3.3
Location : trySplit
Killed by : com.pivovarit.collectors.BatchingSpliteratorTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.BatchingSpliteratorTest]/[method:shouldHandleEmptyList()] negated conditional → KILLED

4.4
Location : trySplit
Killed by : com.pivovarit.collectors.BatchingSpliteratorTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.BatchingSpliteratorTest]/[method:shouldSplitAndProcessIndependently()] negated conditional → KILLED

89

1.1
Location : trySplit
Killed by : com.pivovarit.collectors.BatchingSpliteratorTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.BatchingSpliteratorTest]/[method:shouldSplitAndProcessIndependently()] Replaced integer division with multiplication → KILLED

90

1.1
Location : trySplit
Killed by : com.pivovarit.collectors.BatchingSpliteratorTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.BatchingSpliteratorTest]/[method:shouldSplitAndProcessIndependently()] Replaced integer multiplication with division → KILLED

92

1.1
Location : trySplit
Killed by : com.pivovarit.collectors.BatchingSpliteratorTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.BatchingSpliteratorTest]/[method:shouldSplitAndProcessIndependently()] Replaced integer addition with subtraction → KILLED

95

1.1
Location : trySplit
Killed by : com.pivovarit.collectors.BatchingSpliteratorTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.BatchingSpliteratorTest]/[method:shouldSplitAndProcessIndependently()] Replaced integer addition with subtraction → KILLED

96

1.1
Location : trySplit
Killed by : com.pivovarit.collectors.BatchingSpliteratorTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.BatchingSpliteratorTest]/[method:shouldSplitAndProcessIndependently()] Replaced integer subtraction with addition → KILLED

97

1.1
Location : trySplit
Killed by : com.pivovarit.collectors.BatchingSpliteratorTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.BatchingSpliteratorTest]/[method:shouldSplitAndProcessIndependently()] Replaced integer subtraction with addition → KILLED

98

1.1
Location : trySplit
Killed by : com.pivovarit.collectors.BatchingSpliteratorTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.BatchingSpliteratorTest]/[method:shouldSplitAndProcessIndependently()] Replaced integer subtraction with addition → KILLED

2.2
Location : trySplit
Killed by : com.pivovarit.collectors.BatchingSpliteratorTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.BatchingSpliteratorTest]/[method:shouldSplitAndProcessIndependently()] Replaced double division with multiplication → KILLED

100

1.1
Location : trySplit
Killed by : com.pivovarit.collectors.BatchingSpliteratorTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.BatchingSpliteratorTest]/[method:shouldSplitAndProcessIndependently()] replaced return value with null for com/pivovarit/collectors/BatchingSpliterator::trySplit → KILLED

105

1.1
Location : estimateSize
Killed by : com.pivovarit.collectors.BatchingSpliteratorTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.BatchingSpliteratorTest]/[method:shouldReportCorrectSizeWhenMultipleBatches()] replaced long return with 0 for com/pivovarit/collectors/BatchingSpliterator::estimateSize → KILLED

110

1.1
Location : characteristics
Killed by : com.pivovarit.collectors.BatchingSpliteratorTest.[engine:junit-jupiter]/[class:com.pivovarit.collectors.BatchingSpliteratorTest]/[method:shouldReportOrderedSizedAndSubSized()] replaced int return with 0 for com/pivovarit/collectors/BatchingSpliterator::characteristics → KILLED

Active mutators

Tests examined


Report generated by PIT 1.21.1