Class ReindexRequest<TSource, TTarget>

Inheritance

object

ReindexRequest<TSource, TTarget>

ReindexRequest<TSource>

Implements

IReindexRequest<TSource, TTarget>

Inherited Members

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 ReindexRequest<TSource, TTarget> : IReindexRequest<TSource, TTarget> where TSource : class where TTarget : class

Type Parameters

Name	Description
TSource
TTarget

Constructors

ReindexRequest(IScrollAllRequest, Func<TSource, TTarget>, Func<IEnumerable<IHitMetadata<TTarget>>, IBulkAllRequest<IHitMetadata<TTarget>>>)

Declaration

public ReindexRequest(IScrollAllRequest scrollSource, Func<TSource, TTarget> map, Func<IEnumerable<IHitMetadata<TTarget>>, IBulkAllRequest<IHitMetadata<TTarget>>> bulkAllTarget)

Parameters

Type	Name	Description
IScrollAllRequest	scrollSource	The scroll operation yielding the source documents for the reindex operation
Func<TSource, TTarget>	map	A function that converts from a source document to a target document
Func<IEnumerable<IHitMetadata<TTarget>>, IBulkAllRequest<IHitMetadata<TTarget>>>	bulkAllTarget	A factory that instantiates the bulk all operation over the lazy stream of search result hits

Properties

BackPressureFactor

The scroll typically outperforms the bulk operations by a long shot. If we'd leave things unbounded you'd quickly have way too many pending scroll requests. What this property allows you to express is that for each bucket in the max concurrency of the minimum max concurrency between producer and consumer amply the maximum overal pending of the other side by this factor. Typically the concurrency of the consumer (bulkall) will be lower and with this factor we can dampen the overall pending scroll requests while we are still processing bulk requests.

defaults to 4 if not provided

Declaration

public int? BackPressureFactor { get; set; }

Property Value

Type	Description
int?

CreateIndexRequest

Describe how the newly created index should be created. Remember you can also register Index Templates for more dynamic usecases.

Declaration

public ICreateIndexRequest CreateIndexRequest { get; set; }

Property Value

Type	Description
ICreateIndexRequest

OmitIndexCreation

Do not send a create index call on the target index, assume the index has been created outside of the reindex. Reindex will never create the index if it already exists however this will also omit the IndexExists call.

Declaration

public bool OmitIndexCreation { get; set; }

Property Value

Type	Description
bool

Implements

IReindexRequest<TSource, TTarget>

Extension Methods

SuffixExtensions.Suffix(object, string)