Added missing pipeline aggregations

Original commit by @jonyadamit, squashed, reformatted, introduced
sigma on extendedstatsbucket by @Mpdreamz

Author: jonyadamit

src/Nest/Aggregations/AggregationContainer.cs

@@ -154,8 +154,17 @@ public interface IAggregationContainer
 		IMinBucketAggregation MinBucket { get; set; }
 
 		[JsonProperty("sum_bucket")]
-		ISumBucketAggregation SumBucket { get; set; }
-
+		ISumBucketAggregation SumBucket { get; set; }
+
+		[JsonProperty("stats_bucket")]
+		IStatsBucketAggregation StatsBucket { get; set; }
+
+		[JsonProperty("extended_stats_bucket")]
+		IExtendedStatsBucketAggregation ExtendedStatsBucket { get; set; }
+
+		[JsonProperty("percentiles_bucket")]
+		IPercentilesBucketAggregation PercentilesBucket { get; set; }
+
 		[JsonProperty("moving_avg")]
 		IMovingAverageAggregation MovingAverage { get; set; }
 
@@ -242,8 +251,14 @@ public class AggregationContainer : IAggregationContainer
 
 		public IMinBucketAggregation MinBucket { get; set; }
 
-		public ISumBucketAggregation SumBucket { get; set; }
-
+		public ISumBucketAggregation SumBucket { get; set; }
+
+		public IStatsBucketAggregation StatsBucket { get; set; }
+
+		public IExtendedStatsBucketAggregation ExtendedStatsBucket { get; set; }
+
+		public IPercentilesBucketAggregation PercentilesBucket { get; set; }
+
 		public IMovingAverageAggregation MovingAverage { get; set; }
 
 		public ICumulativeSumAggregation CumulativeSum { get; set; }
@@ -349,8 +364,14 @@ public class AggregationContainerDescriptor<T> : DescriptorBase<AggregationConta
 
 		IMinBucketAggregation IAggregationContainer.MinBucket { get; set; }
 
-		ISumBucketAggregation IAggregationContainer.SumBucket { get; set; }
-
+		ISumBucketAggregation IAggregationContainer.SumBucket { get; set; }
+
+		IStatsBucketAggregation IAggregationContainer.StatsBucket { get; set; }
+
+		IExtendedStatsBucketAggregation IAggregationContainer.ExtendedStatsBucket { get; set; }
+
+		IPercentilesBucketAggregation IAggregationContainer.PercentilesBucket { get; set; }
+
 		IMovingAverageAggregation IAggregationContainer.MovingAverage { get; set; }
 
 		ICumulativeSumAggregation IAggregationContainer.CumulativeSum { get; set; }
@@ -497,8 +518,20 @@ public AggregationContainerDescriptor<T> MinBucket(string name,
 
 		public AggregationContainerDescriptor<T> SumBucket(string name,
 			Func<SumBucketAggregationDescriptor, ISumBucketAggregation> selector) =>
-			_SetInnerAggregation(name, selector, (a, d) => a.SumBucket = d);
-
+			_SetInnerAggregation(name, selector, (a, d) => a.SumBucket = d);
+
+		public AggregationContainerDescriptor<T> StatsBucket(string name,
+			Func<StatsBucketAggregationDescriptor, IStatsBucketAggregation> selector) =>
+			_SetInnerAggregation(name, selector, (a, d) => a.StatsBucket = d);
+
+		public AggregationContainerDescriptor<T> ExtendedStatsBucket(string name,
+			Func<ExtendedStatsBucketAggregationDescriptor, IExtendedStatsBucketAggregation> selector) =>
+			_SetInnerAggregation(name, selector, (a, d) => a.ExtendedStatsBucket = d);
+
+		public AggregationContainerDescriptor<T> PercentilesBucket(string name,
+			Func<PercentilesBucketAggregationDescriptor, IPercentilesBucketAggregation> selector) =>
+			_SetInnerAggregation(name, selector, (a, d) => a.PercentilesBucket = d);
+
 		public AggregationContainerDescriptor<T> MovingAverage(string name,
 			Func<MovingAverageAggregationDescriptor, IMovingAverageAggregation> selector) =>
 			_SetInnerAggregation(name, selector, (a, d) => a.MovingAverage = d);
@@ -521,8 +554,8 @@ public AggregationContainerDescriptor<T> BucketSelector(string name,
 
 		public AggregationContainerDescriptor<T> Sampler(string name,
 			Func<SamplerAggregationDescriptor<T>, ISamplerAggregation> selector) =>
-			_SetInnerAggregation(name, selector, (a, d) => a.Sampler = d);
-
+			_SetInnerAggregation(name, selector, (a, d) => a.Sampler = d);
+
 		/// <summary>
 		/// Fluent methods do not assign to properties on `this` directly but on IAggregationContainers inside `this.Aggregations[string, IContainer]
 		/// </summary>
@@ -534,27 +567,27 @@ Func<TAggregator, TAggregatorInterface> selector
 			where TAggregator : IAggregation, TAggregatorInterface, new()
 			where TAggregatorInterface : IAggregation
 		{
-			var aggregator = selector(new TAggregator());
-
-			//create new isolated container for new aggregator and assign to the right property
+			var aggregator = selector(new TAggregator());
+
+			//create new isolated container for new aggregator and assign to the right property
 			var container = new AggregationContainer() { Meta = aggregator.Meta };
 
-			assignToProperty(container, aggregator);
-
-			//create aggregations dictionary on `this` if it does not exist already
+			assignToProperty(container, aggregator);
+
+			//create aggregations dictionary on `this` if it does not exist already
 			IAggregationContainer self = this;
-			if (self.Aggregations == null) self.Aggregations = new Dictionary<string, IAggregationContainer>();
-
-			//if the aggregator is a bucket aggregator (meaning it contains nested aggregations);
+			if (self.Aggregations == null) self.Aggregations = new Dictionary<string, IAggregationContainer>();
+
+			//if the aggregator is a bucket aggregator (meaning it contains nested aggregations);
 			var bucket = aggregator as IBucketAggregation;
 			if (bucket != null && bucket.Aggregations.HasAny())
-			{
-				//make sure we copy those aggregations to the isolated container's
-				//own .Aggregations container (the one that gets serialized to "aggs")
+			{
+				//make sure we copy those aggregations to the isolated container's
+				//own .Aggregations container (the one that gets serialized to "aggs")
 				IAggregationContainer d = container;
 				d.Aggregations = bucket.Aggregations;
-			}
-			//assign the aggregations container under Aggregations ("aggs" in the json)
+			}
+			//assign the aggregations container under Aggregations ("aggs" in the json)
 			self.Aggregations[key] = container;
 			return this;
 		}
@@ -565,4 +598,4 @@ public void Accept(IAggregationVisitor visitor)
 			new AggregationWalker().Walk(this, visitor);
 		}
 	}
-}
+}

src/Nest/Aggregations/AggregationsHelper.cs

@@ -51,14 +51,20 @@ public ScriptedMetricAggregate ScriptedMetric(string key)
 				: this.TryGet<ScriptedMetricAggregate>(key);
 		}
 
-		public StatsAggregate Stats(string key) => this.TryGet<StatsAggregate>(key);
-
-		public ExtendedStatsAggregate ExtendedStats(string key) => this.TryGet<ExtendedStatsAggregate>(key);
-
+		public StatsAggregate Stats(string key) => this.TryGet<StatsAggregate>(key);
+
+		public StatsAggregate StatsBucket(string key) => this.TryGet<StatsAggregate>(key);
+
+		public ExtendedStatsAggregate ExtendedStats(string key) => this.TryGet<ExtendedStatsAggregate>(key);
+
+		public ExtendedStatsAggregate ExtendedStatsBucket(string key) => this.TryGet<ExtendedStatsAggregate>(key);
+
 		public GeoBoundsAggregate GeoBounds(string key) => this.TryGet<GeoBoundsAggregate>(key);
 
-		public PercentilesAggregate Percentiles(string key) => this.TryGet<PercentilesAggregate>(key);
-
+		public PercentilesAggregate Percentiles(string key) => this.TryGet<PercentilesAggregate>(key);
+
+		public PercentilesAggregate PercentilesBucket(string key) => this.TryGet<PercentilesAggregate>(key);
+
 		public PercentilesAggregate PercentileRanks(string key) => this.TryGet<PercentilesAggregate>(key);
 
 		public TopHitsAggregate TopHits(string key) => this.TryGet<TopHitsAggregate>(key);
@@ -70,8 +76,8 @@ public FiltersAggregate Filters(string key)
 				return named;
 
 			var anonymous = this.TryGet<BucketAggregate>(key);
-			return anonymous != null 
-				? new FiltersAggregate { Buckets = anonymous.Items.OfType<FiltersBucketItem>().ToList(), Meta = anonymous.Meta } 
+			return anonymous != null
+				? new FiltersAggregate { Buckets = anonymous.Items.OfType<FiltersBucketItem>().ToList(), Meta = anonymous.Meta }
 				: null;
 		}
 
@@ -171,4 +177,4 @@ private MultiBucketAggregate<TBucket> GetBucket<TBucket>(string key)
 			};
 		}
 	}
-}
+}

src/Nest/Aggregations/Pipeline/ExtendedStatsBucket/ExtendedStatsBucketAggregation.cs

@@ -0,0 +1,38 @@
+using System.Collections.Generic;
+using Newtonsoft.Json;
+
+namespace Nest
+{
+	[JsonObject(MemberSerialization = MemberSerialization.OptIn)]
+	[ContractJsonConverter(typeof(AggregationJsonConverter<ExtendedStatsBucketAggregation>))]
+	public interface IExtendedStatsBucketAggregation : IPipelineAggregation
+	{
+		[JsonProperty("sigma")]
+		int? Sigma { get; set; }
+	}
+
+	public class ExtendedStatsBucketAggregation
+		: PipelineAggregationBase, IExtendedStatsBucketAggregation
+	{
+		internal ExtendedStatsBucketAggregation() { }
+
+		public ExtendedStatsBucketAggregation(string name, SingleBucketsPath bucketsPath)
+			: base(name, bucketsPath)
+		{ }
+
+		public int? Sigma { get; set; }
+
+		internal override void WrapInContainer(AggregationContainer c) => c.ExtendedStatsBucket = this;
+	}
+
+	public class ExtendedStatsBucketAggregationDescriptor
+		: PipelineAggregationDescriptorBase<ExtendedStatsBucketAggregationDescriptor, IExtendedStatsBucketAggregation, SingleBucketsPath>
+		, IExtendedStatsBucketAggregation
+	{
+
+		int? IExtendedStatsBucketAggregation.Sigma { get; set; }
+
+		public ExtendedStatsBucketAggregationDescriptor Sigma(int? sigma) => Assign(a => a.Sigma = sigma);
+
+	}
+}

src/Nest/Aggregations/Pipeline/PercentilesBucket/PercentilesBucketAggregation.cs

@@ -0,0 +1,43 @@
+using Newtonsoft.Json;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+
+namespace Nest
+{
+	[JsonObject(MemberSerialization = MemberSerialization.OptIn)]
+	[ContractJsonConverter(typeof(AggregationJsonConverter<PercentilesBucketAggregation>))]
+	public interface IPercentilesBucketAggregation : IPipelineAggregation
+	{
+		[JsonProperty("percents")]
+		IEnumerable<double> Percents { get; set; }
+	}
+
+	public class PercentilesBucketAggregation
+		: PipelineAggregationBase, IPercentilesBucketAggregation
+	{
+		public IEnumerable<double> Percents { get; set; }
+
+		internal PercentilesBucketAggregation() { }
+
+		public PercentilesBucketAggregation(string name, SingleBucketsPath bucketsPath)
+			: base(name, bucketsPath)
+		{ }
+
+		internal override void WrapInContainer(AggregationContainer c) => c.PercentilesBucket = this;
+	}
+
+	public class PercentilesBucketAggregationDescriptor
+		: PipelineAggregationDescriptorBase<PercentilesBucketAggregationDescriptor, IPercentilesBucketAggregation, SingleBucketsPath>
+		, IPercentilesBucketAggregation
+	{
+		IEnumerable<double> IPercentilesBucketAggregation.Percents { get; set; }
+
+		public PercentilesBucketAggregationDescriptor Percents(IEnumerable<double> percentages) =>
+			Assign(a => a.Percents = percentages?.ToList());
+
+		public PercentilesBucketAggregationDescriptor Percents(params double[] percentages) =>
+			Assign(a => a.Percents = percentages?.ToList());
+
+	}
+}

src/Nest/Aggregations/Pipeline/StatsBucket/StatsBucketAggregation.cs

@@ -0,0 +1,26 @@
+using Newtonsoft.Json;
+
+namespace Nest
+{
+	[JsonObject(MemberSerialization = MemberSerialization.OptIn)]
+	[ContractJsonConverter(typeof(AggregationJsonConverter<StatsBucketAggregation>))]
+	public interface IStatsBucketAggregation : IPipelineAggregation { }
+
+	public class StatsBucketAggregation
+		: PipelineAggregationBase, IStatsBucketAggregation
+	{
+		internal StatsBucketAggregation() { }
+
+		public StatsBucketAggregation(string name, SingleBucketsPath bucketsPath)
+			: base(name, bucketsPath)
+		{ }
+
+		internal override void WrapInContainer(AggregationContainer c) => c.StatsBucket = this;
+	}
+
+	public class StatsBucketAggregationDescriptor
+		: PipelineAggregationDescriptorBase<StatsBucketAggregationDescriptor, IStatsBucketAggregation, SingleBucketsPath>
+		, IStatsBucketAggregation
+	{
+	}
+}