Add Sort Ingest Processor

See elastic/elasticsearch#17999

Author: russcam

src/Nest/Ingest/PipelineJsonConverter.cs

@@ -76,6 +76,9 @@ private List<IProcessor> GetProcessors(JToken jsonProcessors, JsonSerializer ser
 					case "set":
 						processors.Add(jsonProcessor.ToObject<SetProcessor>(serializer));
 						break;
+					case "sort":
+						processors.Add(jsonProcessor.ToObject<SortProcessor>(serializer));
+						break;
 					case "split":
 						processors.Add(jsonProcessor.ToObject<SplitProcessor>(serializer));
 						break;

src/Nest/Ingest/Processors/SortProcessor.cs

@@ -0,0 +1,56 @@
+using System;
+using System.Collections.Generic;
+using System.Linq.Expressions;
+using Newtonsoft.Json;
+
+namespace Nest
+{
+	/// <summary>
+	/// Sorts the elements of an array ascending or descending. Homogeneous arrays of numbers
+	/// will be sorted numerically, while arrays of strings or heterogeneous arrays
+	///  of strings and numbers will be sorted lexicographically.
+	/// </summary>
+	[JsonObject(MemberSerialization.OptIn)]
+	[JsonConverter(typeof(ProcessorJsonConverter<SortProcessor>))]
+	public interface ISortProcessor : IProcessor
+	{
+		/// <summary>
+		/// The field to be sorted
+		/// </summary>
+		[JsonProperty("field")]
+		Field Field { get; set; }
+
+		/// <summary>
+		/// The sort order to use. Default is ascending.
+		/// </summary>
+		[JsonProperty("order")]
+		SortOrder? Order { get; set; }
+	}
+
+	public class SortProcessor : ProcessorBase, ISortProcessor
+	{
+		protected override string Name => "sort";
+
+		public Field Field { get; set; }
+
+		public SortOrder? Order { get; set; }
+	}
+
+	public class SortProcessorDescriptor<T>
+	: ProcessorDescriptorBase<SortProcessorDescriptor<T>, ISortProcessor>, ISortProcessor
+	where T : class
+	{
+		protected override string Name => "sort";
+
+		Field ISortProcessor.Field { get; set; }
+		SortOrder? ISortProcessor.Order { get; set; }
+
+		public SortProcessorDescriptor<T> Field(Field field) => Assign(a => a.Field = field);
+
+		public SortProcessorDescriptor<T> Field(Expression<Func<T, object>> objectPath) =>
+			Assign(a => a.Field = objectPath);
+
+		public SortProcessorDescriptor<T> Order(SortOrder order = SortOrder.Ascending) =>
+			Assign(a => a.Order = order);
+	}
+}

src/Nest/Ingest/ProcessorsDescriptor.cs

@@ -26,7 +26,6 @@ public ProcessorsDescriptor Convert<T>(Func<ConvertProcessorDescriptor<T>, IConv
 		public ProcessorsDescriptor Date<T>(Func<DateProcessorDescriptor<T>, IDateProcessor> selector) where T : class  =>
 			Assign(a => a.AddIfNotNull(selector?.Invoke(new DateProcessorDescriptor<T>())));
 
-
 		public ProcessorsDescriptor Fail(Func<FailProcessorDescriptor, IFailProcessor> selector) =>
 			Assign(a => a.AddIfNotNull(selector?.Invoke(new FailProcessorDescriptor())));
 
@@ -62,10 +61,16 @@ public ProcessorsDescriptor Remove<T>(Func<RemoveProcessorDescriptor<T>, IRemove
 		public ProcessorsDescriptor Rename<T>(Func<RenameProcessorDescriptor<T>, IRenameProcessor> selector) where T : class  =>
 			Assign(a => a.AddIfNotNull(selector?.Invoke(new RenameProcessorDescriptor<T>())));
 
-
 		public ProcessorsDescriptor Set<T>(Func<SetProcessorDescriptor<T>, ISetProcessor> selector) where T : class  =>
 			Assign(a => a.AddIfNotNull(selector?.Invoke(new SetProcessorDescriptor<T>())));
 
+		/// <summary>
+		/// The Sort processor sorts the elements of an array ascending or descending. Homogeneous arrays of numbers
+		/// will be sorted numerically, while arrays of strings or heterogeneous arrays
+		///  of strings and numbers will be sorted lexicographically.
+		/// </summary>
+		public ProcessorsDescriptor Sort<T>(Func<SortProcessorDescriptor<T>, ISortProcessor> selector) where T : class  =>
+			Assign(a => a.AddIfNotNull(selector?.Invoke(new SortProcessorDescriptor<T>())));
 
 		public ProcessorsDescriptor Split<T>(Func<SplitProcessorDescriptor<T>, ISplitProcessor> selector) where T : class  =>
 			Assign(a => a.AddIfNotNull(selector?.Invoke(new SplitProcessorDescriptor<T>())));

src/Nest/Nest.csproj

@@ -765,6 +765,7 @@
     <Compile Include="Indices\StatusManagement\Upgrade\UpgradeStatus\UpgradeStatusResponseJsonConverter.cs" />
     <Compile Include="Ingest\Processors\GeoIpProcessor.cs" />
     <Compile Include="Ingest\Processors\AttachmentProcessor.cs" />
+    <Compile Include="Ingest\Processors\SortProcessor.cs" />
     <Compile Include="Mapping\AttributeBased\ElasticsearchCorePropertyAttributeBase.cs" />
     <Compile Include="Ingest\DeletePipeline\DeletePipelineRequest.cs" />
     <Compile Include="Ingest\DeletePipeline\DeletePipelineResponse.cs" />