finalize support for window functions with multi-partitioning

Author: fupelaqu

core/src/main/scala/app/softnetwork/elastic/client/ElasticConversion.scala

@@ -369,6 +369,8 @@ trait ElasticConversion {
       // Handle each aggregation with buckets
       bucketAggs.flatMap { case (aggName, buckets, _) =>
         buckets.flatMap { bucket =>
+          val allTopHits = extractAllTopHits(bucket, fieldAliases, aggregations)
+
           val bucketKey = extractBucketKey(bucket)
           val docCount = Option(bucket.get("doc_count"))
             .map(_.asLong())
@@ -377,7 +379,7 @@ trait ElasticConversion {
           val currentContext = parentContext ++ Map(
             aggName                 -> bucketKey,
             s"${aggName}_doc_count" -> docCount
-          )
+          ) ++ allTopHits
 
           // Check for sub-aggregations
           val subAggFields = bucket

core/src/main/scala/app/softnetwork/elastic/client/package.scala

@@ -162,6 +162,8 @@ package object client extends SerializationApi {
     *   - the source field of the aggregation
     * @param windowing
     *   - whether the aggregation is a window function with partitioning
+    * @param bucketPath
+    *   - the bucket path for pipeline aggregations
     */
   case class ClientAggregation(
     aggName: String,