private RemoveAllEntryData[] selectVersionedEntries() {
    int resultSize = 0;
    for (RemoveAllEntryData p : removeAllData) {
      if (p == null || p.isInhibitDistribution()) {
        continue; // skip blanks
      } else if (p.versionTag != null && p.versionTag.hasValidVersion()) {
        resultSize++;
      }
    }
    RemoveAllEntryData[] result = new RemoveAllEntryData[resultSize];
    int ri = 0;
    for (RemoveAllEntryData p : removeAllData) {
      if (p == null || p.isInhibitDistribution()) {
        continue; // skip blanks
      } else if (p.versionTag != null && p.versionTag.hasValidVersion()) {
        result[ri++] = p;
      }
    }
    return result;
  }
Create RemoveAllPRMessages for primary buckets out of this op

@return a HashMap contain RemoveAllPRMessages, key is bucket id
geode-core/src/main/java/org/apache/geode/internal/cache/DistributedRemoveAllOperation.java