8097 improve index speed for many files

doc/release-notes/8097-indexall-performance.md

@@ -0,0 +1,6 @@
+### Indexing performance on datasets with large numbers of files
+
+We discovered that whenever a full reindexing needs to be performed, datasets with large numbers of files take exceptionally long time to index (for example, in the IQSS repository it takes several hours for a dataset that has 25,000 files). In situations where the Solr index needs to be erased and rebuilt from scratch (such as a Solr version upgrade, or a corrupt index, etc.) this can significantly delay the repopulation of the search catalog. 
+
+We are still investigating the reasons behind this performance issue. For now, even though some improvements have been made, a dataset with thousands of files is still going to take a long time to index. But we've made a simple change to the reindexing process, to index any such datasets at the very end of the batch, after all the datasets with fewer files have been reindexed. This does not improve the overall reindexing time, but will repopulate the bulk of the search index much faster for the users of the installation. 
+

src/main/java/edu/harvard/iq/dataverse/DatasetServiceBean.java

@@ -225,6 +225,51 @@ public List<Long> findAllOrSubset(long numPartitions, long partitionId, boolean
         return typedQuery.getResultList();
     }
 
+        /**
+     * For docs, see the equivalent method on the DataverseServiceBean.
+     * @param numPartitions
+     * @param partitionId
+     * @param skipIndexed
+     * @return a list of datasets
+     * @see DataverseServiceBean#findAllOrSubset(long, long, boolean)
+     */     
+    public List<Long> findAllOrSubsetOrderByFilesOwned(boolean skipIndexed) {
+        /*
+        Disregards deleted or replaced files when determining 'size' of dataset.
+        Could possibly make more efficient by getting file metadata counts
+        of latest published/draft version.
+        Also disregards partitioning which is no longer supported.
+        SEK - 11/09/2021
+        */
+
+        String skipClause = skipIndexed ? "AND o.indexTime is null " : "";
+        Query query = em.createNativeQuery(" Select distinct(o.id), count(f.id) as numFiles FROM dvobject o " +
+            "left join dvobject f on f.owner_id = o.id  where o.dtype = 'Dataset' "
+                + skipClause
+                + " group by o.id "
+                + "ORDER BY count(f.id) asc, o.id");
+
+        List<Object[]> queryResults;
+        queryResults = query.getResultList();
+
+        List<Long> retVal = new ArrayList();
+        for (Object[] result : queryResults) {
+            Long dsId;           
+            if (result[0] != null) {
+                try {
+                    dsId = Long.parseLong(result[0].toString()) ;
+                } catch (Exception ex) {
+                    dsId = null;
+                }
+                if (dsId == null) {
+                    continue;
+                }
+                retVal.add(dsId);
+            }
+        }
+        return retVal;
+    }
+
     /**
      * Merges the passed dataset to the persistence context.
      * @param ds the dataset whose new state we want to persist.

src/main/java/edu/harvard/iq/dataverse/FileMetadata.java

@@ -532,7 +532,7 @@ public boolean contentEquals(FileMetadata other) {
 
     public boolean compareContent(FileMetadata other){
          FileVersionDifference diffObj = new FileVersionDifference(this, other, false);
-         return diffObj.compareMetadata(this, other);
+         return diffObj.isSame();
     }
 
     @Override

src/main/java/edu/harvard/iq/dataverse/FileVersionDifference.java

@@ -10,7 +10,6 @@
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Objects;
-import java.util.ResourceBundle;
 
 /**
  *
@@ -21,6 +20,9 @@ public final class FileVersionDifference {
     private  FileMetadata newFileMetadata;
     private  FileMetadata originalFileMetadata;   
     private boolean details = false;
+    private boolean same = false;
+
+
 
     private List<FileDifferenceSummaryGroup> differenceSummaryGroups = new ArrayList<>();   
     private List<FileDifferenceDetailItem> differenceDetailItems = new ArrayList<>();
@@ -37,7 +39,7 @@ public FileVersionDifference(FileMetadata newFileMetadata, FileMetadata original
         this.originalFileMetadata = originalFileMetadata;
         this.details = details;
 
-        compareMetadata(newFileMetadata, originalFileMetadata);
+        this.same = compareMetadata(newFileMetadata, originalFileMetadata);
         //Compare versions - File Metadata first
 
     } 
@@ -50,7 +52,7 @@ public boolean compareMetadata(FileMetadata newFileMetadata, FileMetadata origin
         and it updates the FileVersionDifference object which is used to display the differences on the dataset versions tab.
         The return value is used by the index service bean tomark whether a file needs to be re-indexed in the context of a dataset update.
         When there are changes (after v4.19)to the file metadata data model this method must be updated.
-        retVal of True means metadatas are equal.
+        retVal of True means metadatas are equal.        
         */        
 
         boolean retVal = true;
@@ -68,13 +70,15 @@ When there are changes (after v4.19)to the file metadata data model this method
 
         if (this.originalFileMetadata == null && this.newFileMetadata.getDataFile() != null ){
             //File Added
+            if (!details) return false;
             retVal = false;
             updateDifferenceSummary( "", BundleUtil.getStringFromBundle("file.versionDifferences.fileGroupTitle"), 1, 0, 0, 0);
         }
 
         //Check to see if File replaced
         if (originalFileMetadata != null &&
                  newFileMetadata.getDataFile() != null && originalFileMetadata.getDataFile() != null &&!this.originalFileMetadata.getDataFile().equals(this.newFileMetadata.getDataFile())){
+            if (!details) return false;
             updateDifferenceSummary( "", BundleUtil.getStringFromBundle("file.versionDifferences.fileGroupTitle"), 0, 0, 0, 1);
             retVal = false;
         }
@@ -83,6 +87,8 @@ When there are changes (after v4.19)to the file metadata data model this method
             if (!newFileMetadata.getLabel().equals(originalFileMetadata.getLabel())) {
                 if (details) {
                     differenceDetailItems.add(new FileDifferenceDetailItem(BundleUtil.getStringFromBundle("file.versionDifferences.fileNameDetailTitle"), originalFileMetadata.getLabel(), newFileMetadata.getLabel()));
+                } else{
+                    return false;
                 }
                 updateDifferenceSummary(BundleUtil.getStringFromBundle("file.versionDifferences.fileMetadataGroupTitle"),
                         BundleUtil.getStringFromBundle("file.versionDifferences.fileNameDetailTitle"), 0, 1, 0, 0);
@@ -97,6 +103,8 @@ When there are changes (after v4.19)to the file metadata data model this method
                     && !newFileMetadata.getDescription().equals(originalFileMetadata.getDescription())) {
                 if (details) {
                     differenceDetailItems.add(new FileDifferenceDetailItem(BundleUtil.getStringFromBundle("file.versionDifferences.descriptionDetailTitle"), originalFileMetadata.getDescription(), newFileMetadata.getDescription()));
+                } else {
+                    return false;
                 }
                 updateDifferenceSummary(BundleUtil.getStringFromBundle("file.versionDifferences.fileMetadataGroupTitle"),
                         BundleUtil.getStringFromBundle("file.versionDifferences.descriptionDetailTitle"), 0, 1, 0, 0);
@@ -107,6 +115,8 @@ When there are changes (after v4.19)to the file metadata data model this method
                     ) {
                 if (details) {
                     differenceDetailItems.add(new FileDifferenceDetailItem(BundleUtil.getStringFromBundle("file.versionDifferences.descriptionDetailTitle"), "", newFileMetadata.getDescription()));
+                } else {
+                    return false;
                 }
                 updateDifferenceSummary(BundleUtil.getStringFromBundle("file.versionDifferences.fileMetadataGroupTitle"),
                         BundleUtil.getStringFromBundle("file.versionDifferences.descriptionDetailTitle"), 1, 0, 0, 0);
@@ -117,6 +127,8 @@ When there are changes (after v4.19)to the file metadata data model this method
                     ) {
                 if (details) {
                     differenceDetailItems.add(new FileDifferenceDetailItem(BundleUtil.getStringFromBundle("file.versionDifferences.descriptionDetailTitle"), originalFileMetadata.getDescription(), "" ));
+                } else {
+                    return false;
                 }
                 updateDifferenceSummary(BundleUtil.getStringFromBundle("file.versionDifferences.fileMetadataGroupTitle"),
                         BundleUtil.getStringFromBundle("file.versionDifferences.descriptionDetailTitle"), 0, 0, 1, 0);
@@ -130,6 +142,8 @@ When there are changes (after v4.19)to the file metadata data model this method
                     && !newFileMetadata.getProvFreeForm().equals(originalFileMetadata.getProvFreeForm())) {
                 if (details) {
                     differenceDetailItems.add(new FileDifferenceDetailItem(BundleUtil.getStringFromBundle("file.versionDifferences.provenanceDetailTitle"), originalFileMetadata.getProvFreeForm(), newFileMetadata.getProvFreeForm()));
+                } else {
+                    return false;
                 }
                 updateDifferenceSummary(BundleUtil.getStringFromBundle("file.versionDifferences.fileMetadataGroupTitle"),
                         BundleUtil.getStringFromBundle("file.versionDifferences.provenanceDetailTitle"), 0, 1, 0, 0);
@@ -140,6 +154,8 @@ When there are changes (after v4.19)to the file metadata data model this method
                     ) {
                 if (details) {
                     differenceDetailItems.add(new FileDifferenceDetailItem(BundleUtil.getStringFromBundle("file.versionDifferences.provenanceDetailTitle"), "", newFileMetadata.getProvFreeForm()));
+                } else {
+                    return false;
                 }
                 updateDifferenceSummary(BundleUtil.getStringFromBundle("file.versionDifferences.fileMetadataGroupTitle"),
                         BundleUtil.getStringFromBundle("file.versionDifferences.provenanceDetailTitle"), 1, 0, 0, 0);
@@ -150,6 +166,8 @@ When there are changes (after v4.19)to the file metadata data model this method
                     ) {
                 if (details) {
                     differenceDetailItems.add(new FileDifferenceDetailItem(BundleUtil.getStringFromBundle("file.versionDifferences.provenanceDetailTitle"), originalFileMetadata.getProvFreeForm(), "" ));
+                } else {
+                    return false;
                 }
                 updateDifferenceSummary(BundleUtil.getStringFromBundle("file.versionDifferences.fileMetadataGroupTitle"),
                         BundleUtil.getStringFromBundle("file.versionDifferences.provenanceDetailTitle"), 0, 0, 1, 0);
@@ -170,7 +188,7 @@ When there are changes (after v4.19)to the file metadata data model this method
             }
 
             if (!value1.equals(value2)) {
-
+                if (!details) return false;
                 int added = 0;
                 int deleted = 0;
 
@@ -254,6 +272,14 @@ public void setOriginalFileMetadata(FileMetadata originalFileMetadata) {
         this.originalFileMetadata = originalFileMetadata;
     }
 
+    public boolean isSame() {
+        return same;
+    }
+
+    public void setSame(boolean same) {
+        this.same = same;
+    }
+
 
     public List<FileDifferenceSummaryGroup> getDifferenceSummaryGroups() {
         return differenceSummaryGroups;

src/main/java/edu/harvard/iq/dataverse/search/IndexBatchServiceBean.java

@@ -1,12 +1,15 @@
 package edu.harvard.iq.dataverse.search;
 
+import edu.harvard.iq.dataverse.Dataset;
 import edu.harvard.iq.dataverse.DatasetServiceBean;
 import edu.harvard.iq.dataverse.Dataverse;
 import edu.harvard.iq.dataverse.DataverseServiceBean;
 import edu.harvard.iq.dataverse.DvObjectServiceBean;
 import edu.harvard.iq.dataverse.util.SystemConfig;
 import java.io.IOException;
+import java.sql.Timestamp;
 import java.util.ArrayList;
+import java.util.Date;
 import java.util.List;
 import java.util.concurrent.Future;
 import java.util.logging.Level;
@@ -200,7 +203,7 @@ public Future<String> indexAllOrSubset(long numPartitions, long partitionId, boo
 
         int datasetIndexCount = 0;
         int datasetFailureCount = 0;
-        List<Long> datasetIds = datasetService.findAllOrSubset(numPartitions, partitionId, skipIndexed);
+        List<Long> datasetIds = datasetService.findAllOrSubsetOrderByFilesOwned(skipIndexed);
         for (Long id : datasetIds) {
             try {
                 datasetIndexCount++;