Class ScrollAllDescriptor<T>
Inheritance
ScrollAllDescriptor<T>
Assembly: OpenSearch.Client.dll
public class ScrollAllDescriptor<T> : DescriptorBase<ScrollAllDescriptor<T>, IScrollAllRequest>, IDescriptor, IScrollAllRequest where T : class
Type Parameters
Constructors
|
Edit this page
View Source
Declaration
public ScrollAllDescriptor(Time scrollTime, int numberOfSlices)
Parameters
| Type |
Name |
Description |
| Time |
scrollTime |
|
| int |
numberOfSlices |
|
Methods
|
Edit this page
View Source
Simple back pressure implementation that makes sure the minimum max concurrency between producer and consumer
is not amplified by the greedier of the two by more then a given back pressure factor
When set each bulk request will call Release()
Declaration
public ScrollAllDescriptor<T> BackPressure(int maxConcurrency, int? backPressureFactor = null)
Parameters
| Type |
Name |
Description |
| int |
maxConcurrency |
The minimum maximum concurrency which would be the bottleneck of the producer consumer pipeline
|
| int? |
backPressureFactor |
The maximum amplification back pressure of the greedier part of the producer consumer pipeline
|
Returns
|
Edit this page
View Source
Declaration
public ScrollAllDescriptor<T> MaxDegreeOfParallelism(int? maxDegreeOfParallelism)
Parameters
| Type |
Name |
Description |
| int? |
maxDegreeOfParallelism |
|
Returns
|
Edit this page
View Source
Declaration
public ScrollAllDescriptor<T> RoutingField(Field field)
Parameters
| Type |
Name |
Description |
| Field |
field |
|
Returns
|
Edit this page
View Source
Declaration
public ScrollAllDescriptor<T> RoutingField<TValue>(Expression<Func<T, TValue>> objectPath)
Parameters
Returns
Type Parameters
|
Edit this page
View Source
Declaration
public ScrollAllDescriptor<T> Search(Func<SearchDescriptor<T>, ISearchRequest> selector)
Parameters
Returns
Implements
Extension Methods