increasing performance for storing entities

gs-gunjan · Jul 25, 2023 · 924fc7f · 924fc7f
1 parent f2a39ea
commit 924fc7f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ain/java/org/finos/legend/depot/store/mongo/versionedEntities/VersionedEntitiesMongo.java b/...ain/java/org/finos/legend/depot/store/mongo/versionedEntities/VersionedEntitiesMongo.java
@@ -64,7 +64,7 @@ protected MongoCollection getCollection()
     public List<StoredVersionedEntity> createOrUpdate(String groupId, String artifactId, String versionId, List<Entity> entityDefinitions)
     {
         List<StoredVersionedEntity> versionedEntities = new ArrayList<>();
-        entityDefinitions.forEach(item ->
+        entityDefinitions.parallelStream().forEach(item ->
         {
             StoredVersionedEntity storedEntity = new StoredVersionedEntityStringData(groupId, artifactId, versionId);
             getCollection().updateOne(getEntityPathFilter(groupId, artifactId, versionId, item.getPath()), combineDocument(storedEntity, item, VERSIONED_ENTITY_TYPE_STRING_DATA), INSERT_IF_ABSENT);