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