A newer version is available. For the latest information, see the
current release documentation.
Cumulative Sum Aggregation Usageedit
Fluent DSL exampleedit
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)
)
.CumulativeSum("cumulative_commits", d => d
.BucketsPath("commits")
)
)
)
Object Initializer syntax exampleedit
new DateHistogramAggregation("projects_started_per_month")
{
Field = "startedOn",
Interval = DateInterval.Month,
Aggregations =
new SumAggregation("commits", "numberOfCommits") &&
new CumulativeSumAggregation("cumulative_commits", "commits")
}
Example json output.
{
"projects_started_per_month": {
"date_histogram": {
"field": "startedOn",
"interval": "month"
},
"aggs": {
"commits": {
"sum": {
"field": "numberOfCommits"
}
},
"cumulative_commits": {
"cumulative_sum": {
"buckets_path": "commits"
}
}
}
}
}
Handling Responsesedit
response.ShouldBeValid();
var projectsPerMonth = response.Aggregations.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 commitsDerivative = item.CumulativeSum("cumulative_commits");
commitsDerivative.Should().NotBeNull();
commitsDerivative.Value.Should().NotBe(null);
}