Skip to content

Commit 5f95c54

Browse files
committed
Remove and undo some more things that were added during bug fixing
1 parent 781328e commit 5f95c54

File tree

5 files changed

+4
-36
lines changed

5 files changed

+4
-36
lines changed

core/src/main/java/org/neo4j/gds/core/loading/CSRGraphStoreUtil.java

Lines changed: 0 additions & 24 deletions
Original file line numberDiff line numberDiff line change
@@ -32,19 +32,16 @@
3232
import org.neo4j.gds.api.properties.graph.GraphPropertyStore;
3333
import org.neo4j.gds.api.properties.nodes.NodeProperty;
3434
import org.neo4j.gds.api.properties.nodes.NodePropertyStore;
35-
import org.neo4j.gds.api.properties.nodes.NodePropertyValues;
3635
import org.neo4j.gds.api.schema.Direction;
3736
import org.neo4j.gds.api.schema.GraphSchema;
3837
import org.neo4j.gds.api.schema.NodeSchema;
39-
import org.neo4j.gds.api.schema.PropertySchema;
4038
import org.neo4j.gds.api.schema.RelationshipPropertySchema;
4139
import org.neo4j.gds.api.schema.RelationshipSchema;
4240
import org.neo4j.gds.core.huge.HugeGraph;
4341
import org.neo4j.values.storable.NumberType;
4442

4543
import java.util.Map;
4644
import java.util.Optional;
47-
import java.util.function.Function;
4845

4946
import static org.neo4j.gds.utils.StringFormatting.formatWithLocale;
5047

@@ -180,27 +177,6 @@ private static Optional<RelationshipPropertyStore> constructRelationshipProperti
180177

181178
}
182179

183-
public static void extractNodeProperties(
184-
ImmutableNodes.Builder nodeImportResultBuilder,
185-
Function<String, PropertySchema> nodeSchema,
186-
Map<String, NodePropertyValues> nodeProperties
187-
) {
188-
NodePropertyStore.Builder propertyStoreBuilder = NodePropertyStore.builder();
189-
nodeProperties.forEach((propertyKey, propertyValues) -> {
190-
var propertySchema = nodeSchema.apply(propertyKey);
191-
propertyStoreBuilder.putIfAbsent(
192-
propertyKey,
193-
NodeProperty.of(
194-
propertyKey,
195-
propertySchema.state(),
196-
propertyValues,
197-
propertySchema.defaultValue()
198-
)
199-
);
200-
});
201-
nodeImportResultBuilder.properties(propertyStoreBuilder.build());
202-
}
203-
204180
// TODO: remove this method
205181
public static GraphSchema computeGraphSchema(
206182
Nodes nodes,

core/src/main/java/org/neo4j/gds/core/loading/LazyIdMapBuilder.java

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -23,15 +23,13 @@
2323
import org.neo4j.gds.api.IdMap;
2424
import org.neo4j.gds.api.PartialIdMap;
2525
import org.neo4j.gds.api.properties.nodes.NodePropertyStore;
26-
import org.neo4j.gds.api.properties.nodes.NodePropertyValues;
2726
import org.neo4j.gds.api.schema.NodeSchema;
2827
import org.neo4j.gds.core.loading.construction.GraphFactory;
2928
import org.neo4j.gds.core.loading.construction.NodeLabelToken;
3029
import org.neo4j.gds.core.loading.construction.NodesBuilder;
3130
import org.neo4j.gds.core.loading.construction.PropertyValues;
3231
import org.neo4j.gds.core.utils.paged.ShardedLongLongMap;
3332

34-
import java.util.Map;
3533
import java.util.OptionalLong;
3634
import java.util.concurrent.atomic.AtomicBoolean;
3735

@@ -114,10 +112,6 @@ public interface HighLimitIdMapAndProperties {
114112
NodeSchema schema();
115113

116114
NodePropertyStore propertyStore();
117-
118-
default Map<String, NodePropertyValues> properties() {
119-
return propertyStore().propertyValues();
120-
}
121115
}
122116

123117
public HighLimitIdMapAndProperties build() {

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

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -222,10 +222,9 @@ static RelationshipsBuilder relationshipsBuilder(
222222
Optional<Boolean> validateRelationships,
223223
Optional<Integer> concurrency,
224224
Optional<Boolean> indexInverse,
225-
Optional<ExecutorService> executorService,
226-
Optional<Boolean> loadRelationshipProperties
225+
Optional<ExecutorService> executorService
227226
) {
228-
var doLoadRelationshipProperties = loadRelationshipProperties.orElse(!propertyConfigs.isEmpty());
227+
var loadRelationshipProperties = !propertyConfigs.isEmpty();
229228

230229
var aggregations = propertyConfigs.isEmpty()
231230
? new Aggregation[]{aggregation.orElse(Aggregation.DEFAULT)}
@@ -291,7 +290,7 @@ static RelationshipsBuilder relationshipsBuilder(
291290
.bufferSize(bufferSize)
292291
.propertyConfigs(propertyConfigs)
293292
.isMultiGraph(isMultiGraph)
294-
.loadRelationshipProperty(doLoadRelationshipProperties)
293+
.loadRelationshipProperty(loadRelationshipProperties)
295294
.direction(Direction.fromOrientation(actualOrientation))
296295
.executorService(executorService.orElse(Pools.DEFAULT))
297296
.concurrency(finalConcurrency);

cypher-aggregation/src/main/java/org/neo4j/gds/projection/GraphAggregator.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -518,7 +518,6 @@ private AdjacencyCompressor.ValueMapper buildNodesWithProperties(GraphStoreBuild
518518
.properties(idMapAndProperties.propertyStore())
519519
.build();
520520

521-
// graphStoreBuilder.nodes(nodesBuilder.schema(nodeSchema).build());
522521
graphStoreBuilder.nodes(nodes);
523522

524523
// Relationships are added using their intermediate node ids.

graph-schema-api/src/main/java/org/neo4j/gds/api/schema/RelationshipSchemaEntry.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -65,7 +65,7 @@ boolean isUndirected() {
6565
}
6666

6767
@Override
68-
public RelationshipSchemaEntry union(RelationshipSchemaEntry other) {
68+
RelationshipSchemaEntry union(RelationshipSchemaEntry other) {
6969
if (!other.identifier().equals(this.identifier())) {
7070
throw new UnsupportedOperationException(
7171
formatWithLocale(

0 commit comments

Comments
 (0)