Tablestore：Aggregasi

Metode agregasi ini digunakan untuk mengembalikan nilai minimum dari sebuah bidang, mirip dengan fungsi MIN() dalam SQL.

• Parameter

  Parameter	Deskripsi
  AggName	Nama unik operasi agregasi. Anda dapat menanyakan hasil operasi agregasi tertentu berdasarkan nama ini.
  FieldName	Nama bidang yang digunakan untuk melakukan operasi agregasi. Hanya tipe LONG, DOUBLE, dan DATE yang didukung.
  Missing	Nilai default untuk bidang yang digunakan untuk melakukan operasi agregasi pada baris ketika nilai bidang kosong. Jika Anda tidak menentukan nilai untuk Missing, baris akan diabaikan. Jika Anda menentukan nilai untuk Missing, nilai parameter ini digunakan sebagai nilai bidang baris tersebut.

• Contoh

  /// <summary>
  /// Nilai minimum.
  /// </summary>
  /// <param name="otsClient"></param>
  public static void MinAggregation(OTSClient otsClient)
  {
      MinAggregation minAggregation = new MinAggregation();
      minAggregation.AggName = "Min_Agg";
      minAggregation.FieldName = "pk1";
  
      RangeQuery rangeQuery = new RangeQuery();
      rangeQuery.FieldName = "pk1";
      rangeQuery.From = new ColumnValue(0);
      rangeQuery.To = new ColumnValue(100);
  
      SearchQuery seachQuery = new SearchQuery
      {
          Limit = 0,
          Query = rangeQuery,
          AggregationList = new List<IAggregation>
          {
              minAggregation
          }
      };
  
      SearchRequest searchRequest = new SearchRequest(TableName, IndexName, seachQuery);
  
      SearchResponse searchResponse = otsClient.Search(searchRequest);
  
      Console.WriteLine(JsonConvert.SerializeObject(searchResponse.AggregationResults.GetAsMinAggregationResult("Min_Agg")));
  }

Metode agregasi ini digunakan untuk mengembalikan nilai maksimum dari sebuah bidang, mirip dengan fungsi MAX() dalam SQL.

• Parameter

  Parameter	Deskripsi
  AggName	Nama unik operasi agregasi. Anda dapat menanyakan hasil operasi agregasi tertentu berdasarkan nama ini.
  FieldName	Nama bidang yang digunakan untuk melakukan operasi agregasi. Hanya tipe LONG, DOUBLE, dan DATE yang didukung.
  Missing	Nilai default untuk bidang yang digunakan untuk melakukan operasi agregasi pada baris ketika nilai bidang kosong. Jika Anda tidak menentukan nilai untuk Missing, baris akan diabaikan. Jika Anda menentukan nilai untuk Missing, nilai parameter ini digunakan sebagai nilai bidang baris tersebut.

• Contoh

  /// <summary>
  /// Nilai maksimum.
  /// </summary>
  /// <param name="otsClient"></param>
  public static void MaxAggregation(OTSClient otsClient)
  {
      MaxAggregation maxAggregation = new MaxAggregation();
      maxAggregation.AggName = "Max_Agg";
      maxAggregation.FieldName = "pk1";
  
      RangeQuery rangeQuery = new RangeQuery();
      rangeQuery.FieldName = "pk1";
      rangeQuery.From = new ColumnValue(0);
      rangeQuery.To = new ColumnValue(100);
  
      SearchQuery seachQuery = new SearchQuery
      {
          Limit = 0,
          Query = rangeQuery,
          AggregationList = new List<IAggregation>
          {
              maxAggregation
          }
      };
  
      SearchRequest searchRequest = new SearchRequest(TableName, IndexName, seachQuery);
  
      SearchResponse searchResponse = otsClient.Search(searchRequest);
  
      Console.WriteLine(JsonConvert.SerializeObject(searchResponse.AggregationResults.GetAsMaxAggregationResult("Max_Agg")));
  }

Metode agregasi ini digunakan untuk mengembalikan total jumlah semua nilai numerik dalam sebuah bidang, mirip dengan fungsi SUM() dalam SQL.

• Parameter

  Parameter	Deskripsi
  AggName	Nama unik operasi agregasi. Anda dapat menanyakan hasil operasi agregasi tertentu berdasarkan nama ini.
  FieldName	Nama bidang yang digunakan untuk melakukan operasi agregasi. Hanya tipe LONG dan DOUBLE yang didukung.
  Missing	Nilai default untuk bidang yang digunakan untuk melakukan operasi agregasi pada baris ketika nilai bidang kosong. Jika Anda tidak menentukan nilai untuk Missing, baris akan diabaikan. Jika Anda menentukan nilai untuk Missing, nilai parameter ini digunakan sebagai nilai bidang baris tersebut.

• Contoh

  /// <summary>
  /// Jumlah.
  /// </summary>
  /// <param name="otsClient"></param>
  public static void SumAggregation(OTSClient otsClient)
  {
      SumAggregation sumAggregation = new SumAggregation();
      sumAggregation.AggName = "Sum_Agg";
      sumAggregation.FieldName = "pk1";
  
      RangeQuery rangeQuery = new RangeQuery();
      rangeQuery.FieldName = "pk1";
      rangeQuery.From = new ColumnValue(0);
      rangeQuery.To = new ColumnValue(100);
  
      SearchQuery seachQuery = new SearchQuery
      {
          Limit = 0,
          Query = rangeQuery,
          AggregationList = new List<IAggregation>
          {
              sumAggregation
          }
      };
  
      SearchRequest searchRequest = new SearchRequest(TableName, IndexName, seachQuery);
  
      SearchResponse searchResponse = otsClient.Search(searchRequest);
  
      Console.WriteLine(JsonConvert.SerializeObject(searchResponse.AggregationResults.GetAsSumAggregationResult("Sum_Agg")));
  }

Metode agregasi ini digunakan untuk mengembalikan rata-rata semua nilai numerik dalam sebuah bidang, mirip dengan fungsi AVG() dalam SQL.

• Parameter

  Parameter	Deskripsi
  AggName	Nama unik operasi agregasi. Anda dapat menanyakan hasil operasi agregasi tertentu berdasarkan nama ini.
  FieldName	Nama bidang yang digunakan untuk melakukan operasi agregasi. Hanya tipe LONG, DOUBLE, dan DATE yang didukung.
  Missing	Nilai default untuk bidang yang digunakan untuk melakukan operasi agregasi pada baris ketika nilai bidang kosong. Jika Anda tidak menentukan nilai untuk Missing, baris akan diabaikan. Jika Anda menentukan nilai untuk Missing, nilai parameter ini digunakan sebagai nilai bidang baris tersebut.

• Contoh

  /// <summary>
  /// Nilai rata-rata.
  /// </summary>
  /// <param name="otsClient"></param>
  public static void AvgAggregation(OTSClient otsClient)
  {
      AvgAggregation avgAggregation = new AvgAggregation();
      avgAggregation.AggName = "Avg_Agg";
      avgAggregation.FieldName = "pk1";
  
      RangeQuery rangeQuery = new RangeQuery();
      rangeQuery.FieldName = "pk1";
      rangeQuery.From = new ColumnValue(0);
      rangeQuery.To = new ColumnValue(100);
  
      SearchQuery seachQuery = new SearchQuery
      {
          Limit = 0,
          Query = rangeQuery,
          AggregationList = new List<IAggregation>
          {
              avgAggregation
          }
      };
  
      SearchRequest searchRequest = new SearchRequest(TableName, IndexName, seachQuery);
  
      SearchResponse searchResponse = otsClient.Search(searchRequest);
  
      Console.WriteLine(JsonConvert.SerializeObject(searchResponse.AggregationResults.GetAsAvgAggregationResult("Avg_Agg")));
  }

• Parameter

  Parameter	Deskripsi
  AggName	Nama unik operasi agregasi. Anda dapat menanyakan hasil operasi agregasi tertentu berdasarkan nama ini.
  FieldName	Nama bidang yang digunakan untuk melakukan operasi agregasi. Hanya tipe LONG, DOUBLE, BOOLEAN, KEYWORD, GEO_POINT, dan DATE yang didukung.

• Contoh

  /// <summary>
  /// Hitungan.
  /// </summary>
  /// <param name="otsClient"></param>
  public static void CountAggregation(OTSClient otsClient)
  {
      CountAggregation countAggregation = new CountAggregation();
      countAggregation.AggName = "Count_Agg";
      countAggregation.FieldName = "pk1";
  
      RangeQuery rangeQuery = new RangeQuery();
      rangeQuery.FieldName = "pk1";
      rangeQuery.From = new ColumnValue(0);
      rangeQuery.To = new ColumnValue(100);
  
      SearchQuery seachQuery = new SearchQuery
      {
          Limit = 0,
          Query = rangeQuery,
          AggregationList = new List<IAggregation>
          {
              countAggregation
          }
      };
  
      SearchRequest searchRequest = new SearchRequest(TableName, IndexName, seachQuery);
  
      SearchResponse searchResponse = otsClient.Search(searchRequest);
  
      Console.WriteLine(JsonConvert.SerializeObject(searchResponse.AggregationResults.GetAsCountAggregationResult("Count_Agg")));
  }

• Parameter

  Parameter	Deskripsi
  AggName	Nama unik operasi agregasi. Anda dapat menanyakan hasil operasi agregasi tertentu berdasarkan nama ini.
  NamaBidang	Nama bidang yang digunakan untuk melakukan operasi agregasi. Hanya tipe LONG, DOUBLE, BOOLEAN, KEYWORD, GEO_POINT, dan DATE yang didukung.
  Kosong	Nilai default untuk bidang yang digunakan untuk melakukan operasi agregasi pada baris ketika nilai bidang kosong. Jika Anda tidak menentukan nilai untuk Kosong, baris akan diabaikan. Jika Anda menentukan nilai untuk Kosong, nilai dari parameter ini digunakan sebagai nilai bidang dari baris tersebut.

• Contoh

  /// <summary>
  /// Hitungan unik.
  /// </summary>
  /// <param name="otsClient"></param>
  public static void DistinctCountAggregation(OTSClient otsClient)
  {
      DistinctCountAggregation distinctCountAggregation = new DistinctCountAggregation();
      distinctCountAggregation.AggName = "DistinctCount_Agg";
      distinctCountAggregation.FieldName = "pk1";
  
      TermsQuery termsQuery = new TermsQuery();
      termsQuery.FieldName = "pk0";
      termsQuery.Terms = new List<ColumnValue>
      {
          new ColumnValue("Sample"),
          new ColumnValue("SearchIndex")
      };
  
      SearchQuery seachQuery = new SearchQuery
      {
          Limit = 0,
          Query = termsQuery,
          AggregationList = new List<IAggregation>
          {
              distinctCountAggregation
          }
      };
  
      SearchRequest searchRequest = new SearchRequest(TableName, IndexName, seachQuery);
  
      SearchResponse searchResponse = otsClient.Search(searchRequest);
  
      Console.WriteLine(JsonConvert.SerializeObject(searchResponse.AggregationResults.GetAsDistinctCountAggregationResult("DistinctCount_Agg")));
  }

Nilai persentil menunjukkan posisi relatif sebuah nilai dalam dataset. Misalnya, ketika menganalisis waktu respons selama pemeliharaan sistem, Anda dapat menggunakan persentil seperti p25, p50, p90, dan p99 untuk memahami distribusi waktu respons.

• Parameter

  Parameter	Deskripsi
  AggName	Nama unik operasi agregasi. Anda dapat menanyakan hasil operasi agregasi tertentu berdasarkan nama ini.
  FieldName	Nama bidang yang digunakan untuk melakukan operasi agregasi. Hanya tipe LONG, DOUBLE, dan DATE yang didukung.
  Persentil	Persentil seperti p50, p90, dan p99. Anda dapat menentukan satu atau lebih persentil.
  Missing	Nilai default untuk bidang yang digunakan untuk melakukan operasi agregasi pada baris ketika nilai bidang kosong. Jika Anda tidak menentukan nilai untuk Missing, baris akan diabaikan. Jika Anda menentukan nilai untuk Missing, nilai parameter ini digunakan sebagai nilai bidang baris tersebut.

• Contoh

  /// <summary>
  /// Statistik persentil.
  /// </summary>
  /// <param name="otsClient"></param>
  public static void PercentilesAggregation(OTSClient otsClient)
  {
      PercentilesAggregation percentilesAggregation = new PercentilesAggregation();
      percentilesAggregation.AggName = "Percentiles_Agg";
      percentilesAggregation.FieldName = "pk1";
      percentilesAggregation.Missing = new ColumnValue(10);
      percentilesAggregation.Percentiles = new List<double> { 10.0, 30.0, 60.0, 90.0, 100.0 };
  
      MatchAllQuery matchAllQuery = new MatchAllQuery();
  
      SearchQuery searchQuery = new SearchQuery();
      searchQuery.AggregationList = new List<IAggregation> { percentilesAggregation };
      searchQuery.Query = matchAllQuery;
      searchQuery.Limit = 0;
  
      SearchRequest searchRequest = new SearchRequest(TableName, IndexName, searchQuery);
  
      SearchResponse searchResponse = otsClient.Search(searchRequest);
  
      Console.WriteLine(JsonConvert.SerializeObject(searchResponse));
  }

• Parameter

  Parameter	Deskripsi
  GroupByName	Nama unik operasi agregasi. Anda dapat menanyakan hasil operasi agregasi tertentu berdasarkan nama ini.
  FieldName	Nama bidang yang digunakan untuk melakukan operasi agregasi. Hanya tipe LONG, DOUBLE, BOOLEAN, KEYWORD, dan DATE yang didukung.
  Size	Jumlah kelompok yang ingin Anda kembalikan. Nilai default: 10. Nilai maksimum: 2000. Jika jumlah kelompok melebihi 2.000, hanya 2.000 kelompok pertama yang dikembalikan.
  GroupBySorters	Aturan pengurutan untuk kelompok. Secara default, kelompok diurutkan berdasarkan jumlah item dalam kelompok secara menurun. Jika Anda mengonfigurasi beberapa aturan pengurutan, kelompok diurutkan berdasarkan urutan aturan yang dikonfigurasi. Parameter yang didukung: Urutkan berdasarkan nilai dalam urutan abjad. Urutkan berdasarkan nilai dalam urutan abjad terbalik. Urutkan berdasarkan jumlah baris secara menaik. Urutkan berdasarkan jumlah baris secara menurun. Urutkan berdasarkan nilai yang diperoleh dari hasil sub-agregasi secara menaik. Urutkan berdasarkan nilai yang diperoleh dari hasil sub-agregasi secara menurun.
  SubAggregation dan SubGroupBy	Operasi sub-agregasi. Anda dapat melakukan operasi sub-agregasi berdasarkan hasil pengelompokan. Skenario Tanyakan jumlah produk dalam setiap kategori, dan harga produk maksimum dan minimum dalam setiap kategori. Metode Kelompokkan hasil kueri berdasarkan kategori produk untuk mendapatkan jumlah produk dalam setiap kategori. Kemudian, lakukan dua operasi sub-agregasi untuk mendapatkan harga produk maksimum dan minimum dalam setiap kategori. Hasil contoh Buah-buahan: 5. Harga maksimum adalah CNY 15. Harga minimum adalah CNY 3. Perlengkapan mandi: 10. Harga maksimum adalah CNY 98. Harga minimum adalah CNY 1. Perangkat elektronik: 3. Harga maksimum adalah CNY 8.699. Harga minimum adalah CNY 2.300. Produk lainnya: 15. Harga maksimum adalah CNY 1.000. Harga minimum adalah CNY 80.

• Contoh

  /// <summary>
  /// Pengelompokan berdasarkan nilai bidang.
  /// </summary>
  /// <param name="otsClient"></param>
  public static void GroupByField(OTSClient otsClient)
  {
      GroupByField groupByField = new GroupByField
      {
          GroupByName = "GroupBy_Field",
          FieldName = "pk0",
          GroupBySorters = new List<GroupBySorter>{
              new GroupBySorter()
              {
                  RowCountSort = new RowCountSort{ Order = SortOrder.DESC }
              },
              new GroupBySorter()
              {
                  GroupKeySort = new GroupKeySort{ Order = SortOrder.DESC }
              }
          }
      };
  
      MatchAllQuery matchAllQuery = new MatchAllQuery();
  
      SearchQuery searchQuery = new SearchQuery();
      searchQuery.GroupByList = new List<IGroupBy> { groupByField };
      searchQuery.Query = matchAllQuery;
      searchQuery.Limit = 0;
  
      SearchRequest searchRequest = new SearchRequest(TableName, IndexName, searchQuery);
  
      SearchResponse searchResponse = otsClient.Search(searchRequest);
  
      Console.WriteLine(JsonConvert.SerializeObject(searchResponse));
  }

Metode agregasi ini digunakan untuk mengelompokkan hasil kueri berdasarkan rentang nilai sebuah bidang. Nilai dalam rentang tertentu dikelompokkan bersama, dan jumlah nilai dalam setiap rentang dikembalikan.

• Parameter

  Parameter	Deskripsi
  GroupByName	Nama unik operasi agregasi. Anda dapat menanyakan hasil operasi agregasi tertentu berdasarkan nama ini.
  FieldName	Nama bidang yang digunakan untuk melakukan operasi agregasi. Hanya tipe LONG dan DOUBLE yang didukung.
  Range[double_from, double_to)	Rentang nilai untuk pengelompokan. Rentang nilai dapat dimulai dari double.MinValue dan berakhir dengan double.MaxValue.
  SubAggregation dan SubGroupBy	Operasi sub-agregasi. Anda dapat melakukan operasi sub-agregasi berdasarkan hasil pengelompokan. Misalnya, setelah Anda mengelompokkan hasil kueri berdasarkan volume penjualan dan berdasarkan provinsi, Anda dapat memperoleh provinsi yang memiliki proporsi volume penjualan terbesar dalam rentang tertentu. Anda harus menentukan nilai untuk GroupByField dalam GroupByRange untuk melakukan kueri ini.

• Contoh

  /// <summary>
  /// Kueri berdasarkan rentang.
  /// </summary>
  /// <param name="otsClient"></param>
  public static void GroupByRange(OTSClient otsClient)
  {
      GroupByRange groupByRange = new GroupByRange();
      groupByRange.GroupByName = "GroupBy_Range";
      groupByRange.FieldName = "pk1";
      groupByRange.Ranges = new List<Range>
      {
          new Range(double.MinValue, 5.0),
          new Range(5.0, 50.0),
          new Range(50.0, 100.0),
          new Range(100.0, double.MaxValue)
      };
  
      MatchAllQuery matchAllQuery = new MatchAllQuery();
  
      SearchQuery searchQuery = new SearchQuery();
      searchQuery.GroupByList = new List<IGroupBy> { groupByRange };
      searchQuery.Query = matchAllQuery;
      searchQuery.Limit = 0;
  
      SearchRequest searchRequest = new SearchRequest(TableName, IndexName, searchQuery);
  
      SearchResponse searchResponse = otsClient.Search(searchRequest);
  
      Console.WriteLine(JsonConvert.SerializeObject(searchResponse));
  }

Metode agregasi ini digunakan untuk mengelompokkan hasil kueri berdasarkan jarak dari lokasi geografis ke titik pusat. Hasil dalam rentang tertentu dikelompokkan bersama, dan jumlah nilai dalam setiap rentang dikembalikan.

• Parameter

  Parameter	Deskripsi
  GroupByName	Nama unik operasi agregasi. Anda dapat menanyakan hasil operasi agregasi tertentu berdasarkan nama ini.
  FieldName	Nama bidang yang digunakan untuk operasi agregasi. Hanya tipe GEOPOINT yang didukung.
  Origin(double latitude, double longitude)	Garis bujur dan lintang titik pusat. latitude menentukan lintang titik pusat. longitude menentukan bujur titik pusat.
  Range[double_from, double_to)	Rentang jarak yang digunakan untuk pengelompokan. Satuan: meter. Rentang nilai dapat dimulai dari double.MinValue dan berakhir dengan double.MaxValue.
  SubAggregation dan SubGroupBy	Operasi sub-agregasi. Anda dapat melakukan operasi sub-agregasi berdasarkan hasil pengelompokan.

• Contoh

  /// <summary>
  /// Pengelompokan berdasarkan lokasi geografis.
  /// </summary>
  /// <param name="otsClient"></param>
  public static void GroupByGeoDistance(OTSClient otsClient)
  {
      GroupByGeoDistance groupByGeoDistance = new GroupByGeoDistance
      {
          GroupByName = "GroupBy_GeoDistance",
          FieldName = "geo_col",
          Origin = new GeoPoint(0, 0),
          Ranges = new List<Range>
          {
              new Range(double.MinValue , 1000.0),
              new Range(1000.0, 5000.0),
              new Range(5000.0, double.MaxValue)
          }
      };
  
      MatchAllQuery matchAllQuery = new MatchAllQuery();
  
      SearchQuery searchQuery = new SearchQuery();
      searchQuery.GroupByList = new List<IGroupBy> { groupByGeoDistance };
      searchQuery.Query = matchAllQuery;
      searchQuery.Limit = 0;
  
      SearchRequest searchRequest = new SearchRequest(TableName, IndexName, searchQuery);
  
      SearchResponse searchResponse = otsClient.Search(searchRequest);
  
      Console.WriteLine(JsonConvert.SerializeObject(searchResponse));
  }

Metode agregasi ini digunakan untuk menyaring hasil kueri dan mengelompokkannya untuk mendapatkan jumlah hasil yang sesuai dengan setiap filter. Hasil dikembalikan dalam urutan filter yang ditentukan.

• Parameter

  Parameter	Deskripsi
  GroupByName	Nama unik operasi agregasi. Anda dapat menanyakan hasil operasi agregasi tertentu berdasarkan nama ini.
  Filters	Filter yang dapat digunakan untuk kueri. Hasil dikembalikan dalam urutan filter yang ditentukan.
  SubAggregation dan SubGroupBy	Operasi sub-agregasi. Anda dapat melakukan operasi sub-agregasi berdasarkan hasil pengelompokan.

• Contoh

  /// <summary>
  /// Pengelompokan berdasarkan filter.
  /// </summary>
  /// <param name="otsClient"></param>
  public static void GroupByFilter(OTSClient otsClient)
  {
      GroupByFilter groupByFilter = new GroupByFilter
      {
          GroupByName = "GroupBy_Filter",
          Filters = new List<IQuery>
          {
              new RangeQuery
              {
                  FieldName = "pk1",
                  From = new ColumnValue(0.0),
                  To = new ColumnValue(5.0)
              },
          }
      };
  
      TermsQuery termsQuery = new TermsQuery();
      termsQuery.FieldName = "pk0";
      termsQuery.Terms = new List<ColumnValue>
      {
          new ColumnValue("Tablestore SearchIndex"),
          new ColumnValue("SearchIndex")
      };
  
      SearchQuery searchQuery = new SearchQuery();
      searchQuery.GroupByList = new List<IGroupBy> { groupByFilter };
      searchQuery.Query = termsQuery;
      searchQuery.Limit = 0;
  
      SearchRequest searchRequest = new SearchRequest(TableName, IndexName, searchQuery);
  
      SearchResponse searchResponse = otsClient.Search(searchRequest);
  
      Console.WriteLine(JsonConvert.SerializeObject(searchResponse));
  }

Metode agregasi ini digunakan untuk mengelompokkan hasil kueri berdasarkan interval data tertentu. Nilai dalam rentang yang sama dikelompokkan bersama, dan rentang serta jumlah nilai dalam setiap kelompok dikembalikan.

• Parameter

  Parameter	Deskripsi
  GroupByName	Nama unik operasi agregasi. Anda dapat menanyakan hasil operasi agregasi tertentu berdasarkan nama ini.
  FieldName	Nama bidang yang digunakan untuk melakukan operasi agregasi. Hanya tipe LONG dan DOUBLE yang didukung.
  Interval	Interval data yang digunakan untuk mendapatkan hasil agregasi.
  FieldRange[min,max]	Rentang yang digunakan bersama dengan parameter interval untuk membatasi jumlah kelompok. Nilai yang dihitung menggunakan rumus (FieldRange.max-FieldRange.min)/interval tidak boleh melebihi 2.000.
  MinDocCount	Jumlah baris minimum. Jika jumlah baris dalam kelompok kurang dari jumlah baris minimum, hasil agregasi untuk kelompok tersebut tidak dikembalikan.
  Missing	Nilai default untuk bidang yang digunakan untuk melakukan operasi agregasi pada baris ketika nilai bidang kosong. Jika Anda tidak menentukan nilai untuk Missing, baris akan diabaikan. Jika Anda menentukan nilai untuk Missing, nilai parameter ini digunakan sebagai nilai bidang baris tersebut.

• Contoh

  /// <summary>
  /// Kueri berdasarkan histogram.
  /// </summary>
  /// <param name="otsClient"></param>
  public static void HistogramAggregation(OTSClient otsClient)
  {
      GroupByHistogram groupByHistogram = new GroupByHistogram();
      groupByHistogram.GroupByName = "GroupBy_Histogram";
      groupByHistogram.FieldName = "pk1";
      groupByHistogram.Interval = new ColumnValue(5);
      groupByHistogram.Missing = new ColumnValue(100);
      groupByHistogram.FieldRange = new FieldRange(new ColumnValue(0), new ColumnValue(1000));
  
      MatchAllQuery matchAllQuery = new MatchAllQuery(); ;
  
      SearchQuery searchQuery = new SearchQuery();
      searchQuery.Query = matchAllQuery;
      searchQuery.Limit = 0;
      searchQuery.GroupByList = new List<IGroupBy>
      {
          groupByHistogram
      };
  
      SearchRequest searchRequest = new SearchRequest(TableName, IndexName, searchQuery);
  
      SearchResponse searchResponse = otsClient.Search(searchRequest);
  
      foreach (GroupByHistogramResultItem item in searchResponse.GroupByResults.GetAsGroupByHistogramResult("GroupBy_Histogram").GroupByHistogramResultItems)
      {
          Console.WriteLine(JsonConvert.SerializeObject(item));
      }
  }

Setelah mengelompokkan hasil kueri, Anda dapat menanyakan baris dalam setiap kelompok. Metode ini mirip dengan fungsi ANY_VALUE(bidang) dalam MySQL.

• Parameter

  Parameter	Deskripsi
  AggName	Nama unik operasi agregasi. Anda dapat menanyakan hasil operasi agregasi tertentu berdasarkan nama ini.
  Limit	Jumlah maksimum baris yang dapat dikembalikan untuk setiap kelompok. Secara default, hanya satu baris data yang dikembalikan.
  Sort	Metode pengurutan yang digunakan untuk mengurutkan data dalam kelompok.
  ColumnsToGet	Bidang yang ingin Anda kembalikan. Hanya bidang dalam indeks pencarian yang didukung. Bidang ARRAY, DATE, GEOPOINT, dan NESTED tidak didukung. Nilai parameter ini sama dengan nilai columnsToGet dalam SearchRequest. Anda hanya perlu menentukan columnsToGet dalam SearchRequest.

• Contoh

  /// <summary>
  /// Meminta baris yang diperoleh dari hasil operasi agregasi di setiap grup.
  /// </summary>
  /// <param name="otsClient"></param>
  public static void TopRowsAggregation(OTSClient otsClient)
  {
      GroupByField groupByField = new GroupByField();
      groupByField.GroupByName = "GroupBy_Field";
      groupByField.FieldName = "pk0";
      groupByField.SubAggregations = new List<IAggregation>
      {
          new TopRowsAggregation
          {
              AggName = "TopRows_Agg",
              Sort = new Sort(new List<ISorter> { new FieldSort("pk1", SortOrder.DESC) }),
              Limit = 2
          }
      };
  
      MatchAllQuery matchAllQuery = new MatchAllQuery(); ;
  
      SearchQuery searchQuery = new SearchQuery();
      searchQuery.Query = matchAllQuery;
      searchQuery.Limit = 0;
      searchQuery.GroupByList = new List<IGroupBy>
      {
          groupByField
      };
  
      SearchRequest searchRequest = new SearchRequest(TableName, IndexName, searchQuery);
  
      SearchResponse searchResponse = otsClient.Search(searchRequest);
  
      foreach (GroupByFieldResultItem item in searchResponse.GroupByResults.GetAsGroupByFieldResult("GroupBy_Field").GroupByFieldResultItems)
      {
          foreach (Row row in item.SubAggregationResults.GetAsTopRowsAggregationResult("TopRows_Agg").Rows)
          {
              Console.WriteLine(JsonConvert.SerializeObject(row));
          }
      }
  }

GroupBy mendukung pengelompokan bersarang. Anda dapat melakukan operasi sub-agregasi menggunakan GroupBy.

Pengelompokan bersarang memungkinkan operasi sub-agregasi dalam kelompok. Misalnya, Anda dapat melakukan operasi agregasi bersarang hingga dua tingkat.

• GroupBy + SubGroupBy: Item dikelompokkan berdasarkan provinsi dan kota untuk mendapatkan data setiap kota di setiap provinsi.

• GroupBy + SubAggregation: Item dikelompokkan berdasarkan provinsi dan nilai maksimum metrik dihitung untuk mendapatkan nilai maksimum metrik di setiap provinsi.

/// <summary>
/// Bersarang.
/// </summary>
/// <param name="otsClient"></param>
public static void SubGroupBy(OTSClient otsClient)
{
    GroupByField groupByField = new GroupByField();
    groupByField.GroupByName = "Field_GroupBy";
    groupByField.FieldName = "pk0";
    groupByField.SubGroupBys = new List<IGroupBy>
    {
        new GroupByRange
        {
            GroupByName = "Range_GroupBy",
            FieldName = "pk1",
            Ranges = new List<Range>
            {
                new Range(double.MinValue, 5),
                new Range(5,100),
                new Range(100, double.MaxValue)
            }

        }
    };

    MatchAllQuery matchAllQuery = new MatchAllQuery();

    SearchQuery searchQuery = new SearchQuery();
    searchQuery.GroupByList = new List<IGroupBy>
    {
        groupByField
    };
    searchQuery.GetTotalCount = true;
    searchQuery.Limit = 0;
    searchQuery.Query = matchAllQuery;

    SearchRequest searchRequest = new SearchRequest(TableName, IndexName, searchQuery);

    SearchResponse searchResponse = otsClient.Search(searchRequest);

    foreach (GroupByFieldResultItem item in searchResponse.GroupByResults.GetAsGroupByFieldResult("Field_GroupBy").GroupByFieldResultItems)
    {
        Console.WriteLine(JsonConvert.SerializeObject(item.SubGroupByResults.GetAsGroupByRangeResult("Range_GroupBy")));
    }
}

/// <summary>
/// Beberapa agregasi.
/// </summary>
/// <param name="otsClient"></param>
public static void MultipleAggregation(OTSClient otsClient)
{
    MaxAggregation maxAggregation = new MaxAggregation();
    maxAggregation.AggName = "Max_Agg";
    maxAggregation.FieldName = "pk1";

    MinAggregation minAggregation = new MinAggregation();
    minAggregation.AggName = "Min_Agg";
    minAggregation.FieldName = "pk1";

    SumAggregation sumAggregation = new SumAggregation();
    sumAggregation.AggName = "Sum_Agg";
    sumAggregation.FieldName = "pk1";

    SearchQuery searchQuery = new SearchQuery();
    searchQuery.Limit = 0;
    searchQuery.Query = new MatchAllQuery();
    searchQuery.AggregationList = new List<IAggregation>
    {
        maxAggregation,
        minAggregation,
        sumAggregation
    };

    SearchRequest searchRequest = new SearchRequest(TableName, IndexName, searchQuery);

    SearchResponse searchResponse = otsClient.Search(searchRequest);

    Console.WriteLine(JsonConvert.SerializeObject(searchResponse));
}