Bucket Selector Aggregation Usageedit
Fluent DSL Exampleedit
s => s .Size(0) .Aggregations(a => a .DateHistogram("projects_started_per_month", dh => dh .Field(p => p.StartedOn) .Interval(DateInterval.Month) .Aggregations(aa => aa .Sum("commits", sm => sm .Field(p => p.NumberOfCommits) ) .BucketSelector("commits_bucket_filter", bs => bs .BucketsPath(bp => bp .Add("totalCommits", "commits") ) .Script(ss => ss.Inline("totalCommits >= 500").Lang("groovy")) ) ) ) )
Object Initializer Syntax Exampleedit
new SearchRequest<Project>() { Size = 0, Aggregations = new DateHistogramAggregation("projects_started_per_month") { Field = "startedOn", Interval = DateInterval.Month, Aggregations = new SumAggregation("commits", "numberOfCommits") && new BucketSelectorAggregation("commits_bucket_filter", new MultiBucketsPath { { "totalCommits", "commits" }, }) { Script = new InlineScript("totalCommits >= 500") { Lang = "groovy" } } } }
Example json output.
{ "size": 0, "aggs": { "projects_started_per_month": { "date_histogram": { "field": "startedOn", "interval": "month" }, "aggs": { "commits": { "sum": { "field": "numberOfCommits" } }, "commits_bucket_filter": { "bucket_selector": { "buckets_path": { "totalCommits": "commits" }, "script": { "inline": "totalCommits >= 500", "lang": "groovy" } } } } } } }
Handling Responsesedit
response.ShouldBeValid(); var projectsPerMonth = response.Aggs.DateHistogram("projects_started_per_month"); projectsPerMonth.Should().NotBeNull(); projectsPerMonth.Buckets.Should().NotBeNull(); projectsPerMonth.Buckets.Count.Should().BeGreaterThan(0); foreach (var item in projectsPerMonth.Buckets) { var commits = item.Sum("commits"); commits.Should().NotBeNull(); commits.Value.Should().BeGreaterOrEqualTo(500); }