Add mongodb indexes

unidev-polydata · May 15, 2023 · 323478a · 323478a
1 parent 2c216b7
commit 323478a
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/polydata-mongodb/src/main/java/com/unidev/polydata4/mongodb/PolydataMongodb.java b/polydata-mongodb/src/main/java/com/unidev/polydata4/mongodb/PolydataMongodb.java
@@ -55,6 +55,8 @@ public PolydataMongodb(String mongoUri) {
 
     public void prepareStorage(String dataset) {
         collection(dataset).createIndex(Indexes.ascending(INDEXES));
+        collection(dataset).createIndex(Indexes.ascending(CREATE_DATE));
+        collection(dataset).createIndex(Indexes.ascending(UPDATE_DATE));
     }
 
     @Override
@@ -463,7 +465,7 @@ private void recalculateIndex(String dataset) {
                         Aggregates.unwind("$" + INDEXES),
                         Aggregates.group("$" + INDEXES, Accumulators.sum("count", 1))
                 )
-        );
+        ).allowDiskUse(true);
 
         try (MongoCursor<Document> iterator = documents.iterator()) {
             BasicPoly indexes = BasicPoly.newPoly(dataset);