IMPORTANT: No additional bug fixes or documentation updates
will be released for this version. For the latest information, see the
current release documentation.
Moving Average Linear Aggregation Usage
edit
IMPORTANT: This documentation is no longer updated. Refer to Elastic's version policy and the latest documentation.
Moving Average Linear Aggregation Usage
editFluent DSL example
edita => a
.DateHistogram("projects_started_per_month", dh => dh
.Field(p => p.StartedOn)
.Interval(DateInterval.Month)
.MinimumDocumentCount(0)
.Aggregations(aa => aa
.Sum("commits", sm => sm
.Field(p => p.NumberOfCommits)
)
.MovingAverage("commits_moving_avg", mv => mv
.BucketsPath("commits")
.GapPolicy(GapPolicy.InsertZeros)
.Model(m => m
.Linear()
)
)
)
)
Object Initializer syntax example
editnew DateHistogramAggregation("projects_started_per_month")
{
Field = "startedOn",
Interval = DateInterval.Month,
MinimumDocumentCount = 0,
Aggregations =
new SumAggregation("commits", "numberOfCommits") &&
new MovingAverageAggregation("commits_moving_avg", "commits")
{
GapPolicy = GapPolicy.InsertZeros,
Model = new LinearModel()
}
}
Example json output.
{
"projects_started_per_month": {
"date_histogram": {
"field": "startedOn",
"interval": "month",
"min_doc_count": 0
},
"aggs": {
"commits": {
"sum": {
"field": "numberOfCommits"
}
},
"commits_moving_avg": {
"moving_avg": {
"buckets_path": "commits",
"gap_policy": "insert_zeros",
"model": "linear",
"settings": {}
}
}
}
}
}
Handling Responses
editresponse.ShouldBeValid();
var projectsPerMonth = response.Aggregations.DateHistogram("projects_started_per_month");
projectsPerMonth.Should().NotBeNull();
projectsPerMonth.Buckets.Should().NotBeNull();
projectsPerMonth.Buckets.Count.Should().BeGreaterThan(0);
// average not calculated for the first bucket
foreach (var item in projectsPerMonth.Buckets.Skip(1))
{
var movingAvg = item.MovingAverage("commits_moving_avg");
movingAvg.Should().NotBeNull();
movingAvg.Value.Should().BeGreaterThan(0);
}