add back old doc values

Signed-off-by: Anthony Leong <aj.leong623@gmail.com>

Author: ajleong623

server/src/main/java/org/opensearch/index/shard/IndexingStats.java

@@ -164,7 +164,8 @@ public void writeTo(StreamOutput out) throws IOException {
         private long maxLastIndexRequestTimestamp;
 
         Stats() {
-            docStatusStats = null;
+            docStatusStats = new DocStatusStats();
+            //docStatusStats = null;
         }
 
         /**
@@ -203,7 +204,7 @@ public Stats(StreamInput in) throws IOException {
             } else {
                 maxLastIndexRequestTimestamp = 0L;
             }
-            if (in.getVersion().onOrAfter(Version.V_2_11_0) && in.getVersion().onOrBefore(Version.V_3_3_0)) {
+            if (in.getVersion().onOrAfter(Version.V_2_11_0) /*&& in.getVersion().onOrBefore(Version.V_3_3_0)*/) {
                 docStatusStats = in.readOptionalWriteable(DocStatusStats::new);
             } else {
                 docStatusStats = null;
@@ -442,7 +443,7 @@ public void writeTo(StreamOutput out) throws IOException {
             if (out.getVersion().onOrAfter(Version.V_3_2_0)) {
                 out.writeLong(maxLastIndexRequestTimestamp);
             }
-            if (out.getVersion().onOrAfter(Version.V_2_11_0) && out.getVersion().onOrBefore(Version.V_3_3_0)) {
+            if (out.getVersion().onOrAfter(Version.V_2_11_0)/* && out.getVersion().onOrBefore(Version.V_3_3_0)*/) {
                 out.writeOptionalWriteable(docStatusStats);
             }
         }
@@ -542,6 +543,12 @@ public Builder isThrottled(boolean throttled) {
                 return this;
             }
 
+            // To be removed soon
+            public Builder docStatusStats(DocStatusStats stats) {
+                this.docStatusStats = stats;
+                return this;
+            }
+
             public Builder maxLastIndexRequestTimestamp(long timestamp) {
                 this.maxLastIndexRequestTimestamp = timestamp;
                 return this;

server/src/main/java/org/opensearch/index/shard/InternalIndexingStats.java

@@ -154,6 +154,7 @@ static class StatsHolder {
         private final MaxMetric maxLastIndexRequestTimestamp = new MaxMetric();
 
         IndexingStats.Stats stats(boolean isThrottled, long currentThrottleMillis) {
+            // DocStatusStats is used here
             return new IndexingStats.Stats.Builder().indexCount(indexMetric.count())
                 .indexTimeInMillis(TimeUnit.NANOSECONDS.toMillis(indexMetric.sum()))
                 .indexCurrent(indexCurrent.count())
@@ -164,6 +165,7 @@ IndexingStats.Stats stats(boolean isThrottled, long currentThrottleMillis) {
                 .noopUpdateCount(noopUpdates.count())
                 .isThrottled(isThrottled)
                 .throttleTimeInMillis(TimeUnit.MILLISECONDS.toMillis(currentThrottleMillis))
+                .docStatusStats(new IndexingStats.Stats.DocStatusStats())
                 .maxLastIndexRequestTimestamp(maxLastIndexRequestTimestamp.get())
                 .build();
         }

server/src/main/java/org/opensearch/indices/IndicesService.java

@@ -1409,7 +1409,7 @@ public void addDocStatusStats(final DocStatusStats stats) {
      */
     @Deprecated(since = "3.4.0")
     public void addDocStatusStats(final org.opensearch.index.shard.IndexingStats.Stats.DocStatusStats stats) {
-
+        oldShardsStats.indexingStats.getTotal().getDocStatusStats().add(stats);
     }
 
     /**