off heap changes

Signed-off-by: Bharathwaj G <bharath78910@gmail.com>
opensearch-project · Jul 18, 2024 · c459d9a · c459d9a
1 parent 6c80d66
commit c459d9a
Show file tree

Hide file tree

Showing 8 changed files with 3,376 additions and 1,247 deletions.
diff --git a/...va/org/opensearch/index/compositeindex/datacube/startree/builder/BaseStarTreeBuilder.java b/...va/org/opensearch/index/compositeindex/datacube/startree/builder/BaseStarTreeBuilder.java
@@ -72,7 +72,7 @@ public abstract class BaseStarTreeBuilder implements StarTreeBuilder {
 
     protected final TreeNode rootNode = getNewNode();
 
-    private final StarTreeField starTreeField;
+    protected final StarTreeField starTreeField;
     private final MapperService mapperService;
     private final SegmentWriteState state;
     static String NUM_SEGMENT_DOCS = "numSegmentDocs";
@@ -163,7 +163,7 @@ public List<MetricAggregatorInfo> generateMetricAggregatorInfos(MapperService ma
      *
      * @return Star tree documents
      */
-    public abstract List<StarTreeDocument> getStarTreeDocuments();
+    public abstract List<StarTreeDocument> getStarTreeDocuments() throws IOException;
 
     /**
      * Returns the value of the dimension for the given dimension id and document in the star-tree.
@@ -310,8 +310,8 @@ protected StarTreeDocument reduceSegmentStarTreeDocuments(
                     StarTreeNumericType starTreeNumericType = metricAggregatorInfos.get(i).getAggregatedValueType();
                     if (isMerge) {
                         aggregatedSegmentDocument.metrics[i] = metricValueAggregator.mergeAggregatedValues(
-                            aggregatedSegmentDocument.metrics[i],
-                            segmentDocument.metrics[i]
+                            segmentDocument.metrics[i],
+                            aggregatedSegmentDocument.metrics[i]
                         );
                     } else {
                         aggregatedSegmentDocument.metrics[i] = metricValueAggregator.mergeAggregatedValueAndSegmentValue(
@@ -714,5 +714,4 @@ private long handleDateDimension(final String fieldName, final long val) {
     public void close() throws IOException {
 
     }
-
 }