Search Results for

    Show / Hide Table of Contents

    Class ScrollAllDescriptor<T>

    Inheritance
    object
    DescriptorBase<ScrollAllDescriptor<T>, IScrollAllRequest>
    ScrollAllDescriptor<T>
    Implements
    IDescriptor
    IScrollAllRequest
    Inherited Members
    DescriptorBase<ScrollAllDescriptor<T>, IScrollAllRequest>.Self
    DescriptorBase<ScrollAllDescriptor<T>, IScrollAllRequest>.Assign<TValue>(TValue, Action<IScrollAllRequest, TValue>)
    object.Equals(object)
    object.Equals(object, object)
    object.GetHashCode()
    object.GetType()
    object.MemberwiseClone()
    object.ReferenceEquals(object, object)
    object.ToString()
    Namespace: OpenSearch.Client
    Assembly: OpenSearch.Client.dll
    Syntax
    public class ScrollAllDescriptor<T> : DescriptorBase<ScrollAllDescriptor<T>, IScrollAllRequest>, IDescriptor, IScrollAllRequest where T : class
    Type Parameters
    Name Description
    T

    Constructors

    | Edit this page View Source

    ScrollAllDescriptor(Time, int)

    Declaration
    public ScrollAllDescriptor(Time scrollTime, int numberOfSlices)
    Parameters
    Type Name Description
    Time scrollTime
    int numberOfSlices

    Methods

    | Edit this page View Source

    BackPressure(int, int?)

    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
    Type Description
    ScrollAllDescriptor<T>
    | Edit this page View Source

    MaxDegreeOfParallelism(int?)

    Declaration
    public ScrollAllDescriptor<T> MaxDegreeOfParallelism(int? maxDegreeOfParallelism)
    Parameters
    Type Name Description
    int? maxDegreeOfParallelism
    Returns
    Type Description
    ScrollAllDescriptor<T>
    | Edit this page View Source

    RoutingField(Field)

    Declaration
    public ScrollAllDescriptor<T> RoutingField(Field field)
    Parameters
    Type Name Description
    Field field
    Returns
    Type Description
    ScrollAllDescriptor<T>
    | Edit this page View Source

    RoutingField<TValue>(Expression<Func<T, TValue>>)

    Declaration
    public ScrollAllDescriptor<T> RoutingField<TValue>(Expression<Func<T, TValue>> objectPath)
    Parameters
    Type Name Description
    Expression<Func<T, TValue>> objectPath
    Returns
    Type Description
    ScrollAllDescriptor<T>
    Type Parameters
    Name Description
    TValue
    | Edit this page View Source

    Search(Func<SearchDescriptor<T>, ISearchRequest>)

    Declaration
    public ScrollAllDescriptor<T> Search(Func<SearchDescriptor<T>, ISearchRequest> selector)
    Parameters
    Type Name Description
    Func<SearchDescriptor<T>, ISearchRequest> selector
    Returns
    Type Description
    ScrollAllDescriptor<T>

    Implements

    IDescriptor
    IScrollAllRequest

    Extension Methods

    SuffixExtensions.Suffix(object, string)
    • Edit this page
    • View Source
    In this article
    • Constructors
      • ScrollAllDescriptor(Time, int)
    • Methods
      • BackPressure(int, int?)
      • MaxDegreeOfParallelism(int?)
      • RoutingField(Field)
      • RoutingField<TValue>(Expression<Func<T, TValue>>)
      • Search(Func<SearchDescriptor<T>, ISearchRequest>)
    • Implements
    • Extension Methods
    Back to top Generated by DocFX