Skip to content

Commit 36268c0

Browse files
s1cksoerenreichardt
andcommitted
Minor name and visibility refactoring
Co-Authored-By: Sören Reichardt <soren.reichardt@neotechnology.com>
1 parent 4f092ea commit 36268c0

File tree

4 files changed

+28
-28
lines changed

4 files changed

+28
-28
lines changed

core/src/main/java/org/neo4j/gds/core/loading/construction/GraphFactory.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -120,7 +120,7 @@ static NodesBuilder nodesBuilder(
120120
)).orElseGet(() -> new NodesBuilder(
121121
maxOriginalId,
122122
threadCount,
123-
TokenToNodeLabelMap.lazy(),
123+
TokenToNodeLabel.lazy(),
124124
NodeLabelTokenToPropertyKeys.lazy(),
125125
new ConcurrentHashMap<>(),
126126
idMapBuilder,
@@ -161,7 +161,7 @@ private static NodesBuilder fromSchema(
161161
return new NodesBuilder(
162162
maxOriginalId,
163163
concurrency,
164-
TokenToNodeLabelMap.fixed(elementIdentifierLabelTokenMapping, labelTokenNodeLabelMapping),
164+
TokenToNodeLabel.fixed(elementIdentifierLabelTokenMapping, labelTokenNodeLabelMapping),
165165
NodeLabelTokenToPropertyKeys.fixed(nodeSchema),
166166
new ConcurrentHashMap<>(propertyBuildersByPropertyKey),
167167
idMapBuilder,

core/src/main/java/org/neo4j/gds/core/loading/construction/NodeLabelTokenToPropertyKeys.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -64,7 +64,7 @@ abstract Map<String, PropertySchema> propertySchemas(
6464
Map<String, PropertySchema> importPropertySchemas
6565
);
6666

67-
static class Fixed extends NodeLabelTokenToPropertyKeys {
67+
private static class Fixed extends NodeLabelTokenToPropertyKeys {
6868

6969
private final NodeSchema nodeSchema;
7070

@@ -98,7 +98,7 @@ Map<String, PropertySchema> propertySchemas(
9898
}
9999
}
100100

101-
static class Lazy extends NodeLabelTokenToPropertyKeys {
101+
private static class Lazy extends NodeLabelTokenToPropertyKeys {
102102

103103
private final ConcurrentHashMap<NodeLabelToken, Set<String>> labelToPropertyKeys;
104104

core/src/main/java/org/neo4j/gds/core/loading/construction/NodesBuilder.java

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -85,7 +85,7 @@ public final class NodesBuilder {
8585
NodesBuilder(
8686
long maxOriginalId,
8787
int concurrency,
88-
TokenToNodeLabelMap tokenToNodeLabelMap,
88+
TokenToNodeLabel tokenToNodeLabel,
8989
NodeLabelTokenToPropertyKeys nodeLabelTokenToPropertyKeys,
9090
ConcurrentMap<String, NodePropertiesFromStoreBuilder> propertyBuildersByPropertyKey,
9191
IdMapBuilder idMapBuilder,
@@ -107,7 +107,7 @@ public final class NodesBuilder {
107107
this.nodeImporter = new NodeImporter(
108108
idMapBuilder,
109109
labelInformationBuilder,
110-
tokenToNodeLabelMap.labelTokenNodeLabelMapping(),
110+
tokenToNodeLabel.labelTokenNodeLabelMapping(),
111111
hasProperties
112112
);
113113

@@ -126,7 +126,7 @@ public final class NodesBuilder {
126126
seenNodeIdPredicate,
127127
hasLabelInformation,
128128
hasProperties,
129-
tokenToNodeLabelMap,
129+
tokenToNodeLabel,
130130
nodeLabelTokenToPropertyKeys,
131131
propertyBuilderFn
132132
)
@@ -287,7 +287,7 @@ private static class ThreadLocalBuilder implements AutoCloseable {
287287

288288
private final LongAdder importedNodes;
289289
private final LongPredicate seenNodeIdPredicate;
290-
private final TokenToNodeLabelMap tokenToNodeLabelMap;
290+
private final TokenToNodeLabel tokenToNodeLabel;
291291
private final NodeLabelTokenToPropertyKeys nodeLabelTokenToPropertyKeys;
292292
private final NodesBatchBuffer buffer;
293293
private final Function<String, NodePropertiesFromStoreBuilder> propertyBuilderFn;
@@ -301,13 +301,13 @@ private static class ThreadLocalBuilder implements AutoCloseable {
301301
LongPredicate seenNodeIdPredicate,
302302
boolean hasLabelInformation,
303303
boolean hasProperties,
304-
TokenToNodeLabelMap tokenToNodeLabelMap,
304+
TokenToNodeLabel tokenToNodeLabel,
305305
NodeLabelTokenToPropertyKeys nodeLabelTokenToPropertyKeys,
306306
Function<String, NodePropertiesFromStoreBuilder> propertyBuilderFn
307307
) {
308308
this.importedNodes = importedNodes;
309309
this.seenNodeIdPredicate = seenNodeIdPredicate;
310-
this.tokenToNodeLabelMap = tokenToNodeLabelMap;
310+
this.tokenToNodeLabel = tokenToNodeLabel;
311311
this.nodeLabelTokenToPropertyKeys = nodeLabelTokenToPropertyKeys;
312312
this.propertyBuilderFn = propertyBuilderFn;
313313

@@ -323,7 +323,7 @@ private static class ThreadLocalBuilder implements AutoCloseable {
323323

324324
public void addNode(long originalId, NodeLabelToken nodeLabels) {
325325
if (!seenNodeIdPredicate.test(originalId)) {
326-
long[] labels = labelTokens(nodeLabels);
326+
long[] labels = getOrCreateLabelTokens(nodeLabels);
327327

328328
buffer.add(originalId, LongPropertyReference.empty(), labels);
329329
if (buffer.isFull()) {
@@ -335,7 +335,7 @@ public void addNode(long originalId, NodeLabelToken nodeLabels) {
335335

336336
public void addNode(long originalId, NodeLabelToken nodeLabels, PropertyValues properties) {
337337
if (!seenNodeIdPredicate.test(originalId)) {
338-
long[] labels = labelTokens(nodeLabels);
338+
long[] labels = getOrCreateLabelTokens(nodeLabels);
339339
this.nodeLabelTokenToPropertyKeys.add(nodeLabels, properties.propertyKeys());
340340

341341
int propertyReference = batchNodeProperties.size();
@@ -349,14 +349,14 @@ public void addNode(long originalId, NodeLabelToken nodeLabels, PropertyValues p
349349
}
350350
}
351351

352-
private long[] labelTokens(NodeLabelToken nodeLabels) {
352+
private long[] getOrCreateLabelTokens(NodeLabelToken nodeLabels) {
353353
if (nodeLabels.isEmpty()) {
354354
return anyLabelArray();
355355
}
356356

357357
long[] labelIds = new long[nodeLabels.size()];
358358
for (int i = 0; i < labelIds.length; i++) {
359-
labelIds[i] = tokenToNodeLabelMap.getTokenForNodeLabel(nodeLabels.get(i));
359+
labelIds[i] = tokenToNodeLabel.getOrCreateToken(nodeLabels.get(i));
360360
}
361361

362362
return labelIds;
@@ -412,7 +412,7 @@ private int importProperty(long neoNodeId, String propertyKey, Value value) {
412412
private long[] anyLabelArray() {
413413
var anyLabelArray = this.anyLabelArray;
414414
if (anyLabelArray[0] == NOT_INITIALIZED) {
415-
anyLabelArray[0] = tokenToNodeLabelMap.getTokenForNodeLabel(NodeLabel.ALL_NODES);
415+
anyLabelArray[0] = tokenToNodeLabel.getOrCreateToken(NodeLabel.ALL_NODES);
416416
}
417417
return anyLabelArray;
418418
}

core/src/main/java/org/neo4j/gds/core/loading/construction/TokenToNodeLabelMap.java renamed to core/src/main/java/org/neo4j/gds/core/loading/construction/TokenToNodeLabel.java

Lines changed: 13 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -32,23 +32,23 @@
3232
import static org.neo4j.gds.core.GraphDimensions.NO_SUCH_LABEL;
3333
import static org.neo4j.gds.utils.StringFormatting.formatWithLocale;
3434

35-
public abstract class TokenToNodeLabelMap {
35+
abstract class TokenToNodeLabel {
3636

3737
final ObjectIntMap<NodeLabel> elementIdentifierLabelTokenMapping;
3838
final IntObjectHashMap<List<NodeLabel>> labelTokenNodeLabelMapping;
3939

40-
public static TokenToNodeLabelMap fixed(
40+
static TokenToNodeLabel fixed(
4141
ObjectIntMap<NodeLabel> elementIdentifierLabelTokenMapping,
4242
IntObjectHashMap<List<NodeLabel>> labelTokenNodeLabelMapping
4343
) {
44-
return new FixedTokenToNodeLabelMap(elementIdentifierLabelTokenMapping, labelTokenNodeLabelMapping);
44+
return new FixedTokenToNodeLabel(elementIdentifierLabelTokenMapping, labelTokenNodeLabelMapping);
4545
}
4646

47-
public static TokenToNodeLabelMap lazy() {
48-
return new LazyTokenToNodeLabelMap();
47+
static TokenToNodeLabel lazy() {
48+
return new LazyTokenToNodeLabel();
4949
}
5050

51-
TokenToNodeLabelMap(
51+
TokenToNodeLabel(
5252
ObjectIntMap<NodeLabel> elementIdentifierLabelTokenMapping,
5353
IntObjectHashMap<List<NodeLabel>> labelTokenNodeLabelMapping
5454
) {
@@ -60,39 +60,39 @@ IntObjectHashMap<List<NodeLabel>> labelTokenNodeLabelMapping() {
6060
return this.labelTokenNodeLabelMapping;
6161
}
6262

63-
public abstract int getTokenForNodeLabel(NodeLabel nodeLabel);
63+
abstract int getOrCreateToken(NodeLabel nodeLabel);
6464

65-
static class FixedTokenToNodeLabelMap extends TokenToNodeLabelMap {
65+
private static class FixedTokenToNodeLabel extends TokenToNodeLabel {
6666

67-
FixedTokenToNodeLabelMap(
67+
FixedTokenToNodeLabel(
6868
ObjectIntMap<NodeLabel> elementIdentifierLabelTokenMapping,
6969
IntObjectHashMap<List<NodeLabel>> labelTokenNodeLabelMapping
7070
) {
7171
super(elementIdentifierLabelTokenMapping, labelTokenNodeLabelMapping);
7272
}
7373

7474
@Override
75-
public int getTokenForNodeLabel(NodeLabel nodeLabel) {
75+
public int getOrCreateToken(NodeLabel nodeLabel) {
7676
if (!elementIdentifierLabelTokenMapping.containsKey(nodeLabel)) {
7777
throw new IllegalArgumentException(formatWithLocale("No token was specified for node label %s", nodeLabel));
7878
}
7979
return elementIdentifierLabelTokenMapping.get(nodeLabel);
8080
}
8181
}
8282

83-
static class LazyTokenToNodeLabelMap extends TokenToNodeLabelMap {
83+
private static class LazyTokenToNodeLabel extends TokenToNodeLabel {
8484

8585
private final Lock lock;
8686
private int nextLabelId;
8787

88-
LazyTokenToNodeLabelMap() {
88+
LazyTokenToNodeLabel() {
8989
super(new ObjectIntScatterMap<>(), new IntObjectHashMap<>());
9090
this.lock = new ReentrantLock(true);
9191
this.nextLabelId = 0;
9292
}
9393

9494
@Override
95-
public int getTokenForNodeLabel(NodeLabel nodeLabel) {
95+
public int getOrCreateToken(NodeLabel nodeLabel) {
9696
var token = elementIdentifierLabelTokenMapping.getOrDefault(nodeLabel, NO_SUCH_LABEL);
9797
if (token == NO_SUCH_LABEL) {
9898
lock.lock();

0 commit comments

Comments
 (0)