Skip to content

Commit 7c9b813

Browse files
committed
Replace per-node bitset update with range update
1 parent 2bfa867 commit 7c9b813

File tree

1 file changed

+1
-8
lines changed

1 file changed

+1
-8
lines changed

core/src/main/java/org/neo4j/graphalgo/core/loading/ScanningNodesImporter.java

Lines changed: 1 addition & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,6 @@
2929
import org.neo4j.graphalgo.api.NodeProperties;
3030
import org.neo4j.graphalgo.config.GraphCreateFromStoreConfig;
3131
import org.neo4j.graphalgo.core.GraphDimensions;
32-
import org.neo4j.graphalgo.core.concurrency.ParallelUtil;
3332
import org.neo4j.graphalgo.core.utils.ProgressLogger;
3433
import org.neo4j.graphalgo.core.utils.TerminationFlag;
3534
import org.neo4j.graphalgo.core.utils.paged.HugeAtomicBitSet;
@@ -40,7 +39,6 @@
4039
import java.util.List;
4140
import java.util.Map;
4241
import java.util.stream.Collectors;
43-
import java.util.stream.LongStream;
4442
import java.util.stream.StreamSupport;
4543

4644
import static org.neo4j.graphalgo.core.GraphDimensions.ANY_LABEL;
@@ -160,12 +158,7 @@ private Map<NodeLabel, HugeAtomicBitSet> initializeLabelBitSets(
160158

161159
// set the whole range for '*' projections
162160
for (NodeLabel starLabel : labelTokenNodeLabelMapping.getOrDefault(ANY_LABEL, Collections.emptyList())) {
163-
var bitSet = nodeLabelBitSetMap.get(starLabel);
164-
ParallelUtil.parallelStreamConsume(
165-
LongStream.range(0, nodeCount),
166-
concurrency,
167-
stream -> stream.forEach(bitSet::set)
168-
);
161+
nodeLabelBitSetMap.get(starLabel).set(0, nodeCount);
169162
}
170163

171164
return nodeLabelBitSetMap;

0 commit comments

Comments
 (0)