Add option to stop machine learning datafeed that finds no data. (#4286)

Implements: elastic/elasticsearch#47922

Author: codebrain

src/Nest/XPack/MachineLearning/Datafeed/DatafeedConfig.cs

@@ -75,5 +75,13 @@ public class DatafeedConfig
 		[DataMember(Name = "scroll_size")]
 		public int? ScrollSize { get; internal set; }
 
+		/// <summary>
+		/// If a real-time datafeed has never seen any data (including during any initial training period) then it will automatically stop
+		/// itself and close its associated job after this many real-time searches that return no documents. In other words, it will
+		/// stop after <see cref="Frequency"/> times <see cref="MaximumEmptySearches"/> of real-time operation. If not set then a datafeed
+		/// with no end time that sees no data will remain started until it is explicitly stopped.
+		/// </summary>
+		[DataMember(Name ="max_empty_searches")]
+		public int? MaximumEmptySearches { get; set; }
 	}
 }

src/Nest/XPack/MachineLearning/PutDatafeed/PutDatafeedRequest.cs

@@ -69,6 +69,17 @@ public partial interface IPutDatafeedRequest
 		/// </summary>
 		[DataMember(Name ="scroll_size")]
 		int? ScrollSize { get; set; }
+
+		/// <summary>
+		/// If a real-time datafeed has never seen any data (including during any initial training period) then it will automatically stop
+		/// itself and close its associated job after this many real-time searches that return no documents. In other words, it will
+		/// stop after <see cref="Frequency"/> times <see cref="MaximumEmptySearches"/> of real-time operation. If not set then a datafeed
+		/// with no end time that sees no data will remain started until it is explicitly stopped.
+		/// <para/>
+		/// By default this setting is not set.
+		/// </summary>
+		[DataMember(Name ="max_empty_searches")]
+		int? MaximumEmptySearches { get; set; }
 	}
 
 	/// <inheritdoc />
@@ -101,6 +112,8 @@ public partial class PutDatafeedRequest
 		/// <inheritdoc />
 		public int? ScrollSize { get; set; }
 
+		/// <inheritdoc />
+		public int? MaximumEmptySearches { get; set; }
 	}
 
 	public partial class PutDatafeedDescriptor<TDocument> where TDocument : class
@@ -114,6 +127,7 @@ public partial class PutDatafeedDescriptor<TDocument> where TDocument : class
 		Time IPutDatafeedRequest.QueryDelay { get; set; }
 		IScriptFields IPutDatafeedRequest.ScriptFields { get; set; }
 		int? IPutDatafeedRequest.ScrollSize { get; set; }
+		int? IPutDatafeedRequest.MaximumEmptySearches { get; set; }
 
 		/// <inheritdoc />
 		public PutDatafeedDescriptor<TDocument> Aggregations(Func<AggregationContainerDescriptor<TDocument>, IAggregationContainer> aggregationsSelector) =>
@@ -152,5 +166,8 @@ public PutDatafeedDescriptor<TDocument> ScriptFields(Func<ScriptFieldsDescriptor
 		/// <inheritdoc />
 		public PutDatafeedDescriptor<TDocument> ScrollSize(int? scrollSize) => Assign(scrollSize, (a, v) => a.ScrollSize = v);
 
+		/// <inheritdoc />
+		public PutDatafeedDescriptor<TDocument> MaximumEmptySearches(int? maximumEmptySearches) =>
+			Assign(maximumEmptySearches, (a, v) => a.MaximumEmptySearches = v);
 	}
 }

src/Nest/XPack/MachineLearning/PutDatafeed/PutDatafeedResponse.cs

@@ -64,5 +64,13 @@ public class PutDatafeedResponse : ResponseBase
 		[DataMember(Name = "scroll_size")]
 		public int? ScrollSize { get; internal set; }
 
+		/// <summary>
+		/// If a real-time datafeed has never seen any data (including during any initial training period) then it will automatically stop
+		/// itself and close its associated job after this many real-time searches that return no documents. In other words, it will
+		/// stop after <see cref="Frequency"/> times <see cref="MaximumEmptySearches"/> of real-time operation. If not set then a datafeed
+		/// with no end time that sees no data will remain started until it is explicitly stopped.
+		/// </summary>
+		[DataMember(Name ="max_empty_searches")]
+		public int? MaximumEmptySearches { get; set; }
 	}
 }

src/Nest/XPack/MachineLearning/UpdateDataFeed/UpdateDatafeedRequest.cs

@@ -68,6 +68,17 @@ public partial interface IUpdateDatafeedRequest
 		/// </summary>
 		[DataMember(Name ="scroll_size")]
 		int? ScrollSize { get; set; }
+
+		/// <summary>
+		/// If a real-time datafeed has never seen any data (including during any initial training period) then it will automatically stop
+		/// itself and close its associated job after this many real-time searches that return no documents. In other words, it will
+		/// stop after <see cref="Frequency"/> times <see cref="MaximumEmptySearches"/> of real-time operation. If not set then a datafeed
+		/// with no end time that sees no data will remain started until it is explicitly stopped.
+		/// <para/>
+		/// The special value `-1` unsets this setting.
+		/// </summary>
+		[DataMember(Name ="max_empty_searches")]
+		int? MaximumEmptySearches { get; set; }
 	}
 
 	/// <inheritdoc />
@@ -100,6 +111,9 @@ public partial class UpdateDatafeedRequest
 
 		/// <inheritdoc />
 		public int? ScrollSize { get; set; }
+
+		/// <inheritdoc />
+		public int? MaximumEmptySearches { get; set; }
 	}
 
 	public partial class UpdateDatafeedDescriptor<TDocument> where TDocument : class
@@ -113,6 +127,7 @@ public partial class UpdateDatafeedDescriptor<TDocument> where TDocument : class
 		Time IUpdateDatafeedRequest.QueryDelay { get; set; }
 		IScriptFields IUpdateDatafeedRequest.ScriptFields { get; set; }
 		int? IUpdateDatafeedRequest.ScrollSize { get; set; }
+		int? IUpdateDatafeedRequest.MaximumEmptySearches { get; set; }
 
 		/// <inheritdoc />
 		public UpdateDatafeedDescriptor<TDocument> Aggregations(Func<AggregationContainerDescriptor<TDocument>, IAggregationContainer> aggregationsSelector) =>
@@ -151,5 +166,9 @@ public UpdateDatafeedDescriptor<TDocument> ScriptFields(Func<ScriptFieldsDescrip
 
 		/// <inheritdoc />
 		public UpdateDatafeedDescriptor<TDocument> ScrollSize(int? scrollSize) => Assign(scrollSize, (a, v) => a.ScrollSize = v);
+
+		/// <inheritdoc />
+		public UpdateDatafeedDescriptor<TDocument> MaximumEmptySearches(int? maximumEmptySearches) =>
+			Assign(maximumEmptySearches, (a, v) => a.MaximumEmptySearches = v);
 	}
 }

src/Nest/XPack/MachineLearning/UpdateDataFeed/UpdateDatafeedResponse.cs

@@ -71,6 +71,14 @@ public class UpdateDatafeedResponse : ResponseBase
 		/// </summary>
 		[DataMember(Name = "scroll_size")]
 		public int? ScrollSize { get; internal set; }
-	}
 
+		/// <summary>
+		/// If a real-time datafeed has never seen any data (including during any initial training period) then it will automatically stop
+		/// itself and close its associated job after this many real-time searches that return no documents. In other words, it will
+		/// stop after <see cref="Frequency"/> times <see cref="MaximumEmptySearches"/> of real-time operation. If not set then a datafeed
+		/// with no end time that sees no data will remain started until it is explicitly stopped.
+		/// </summary>
+		[DataMember(Name ="max_empty_searches")]
+		public int? MaximumEmptySearches { get; set; }
+	}
 }