Class MapReduceOperation<TResult>

Namespace

MongoDB.Driver.Core.Operations

Assembly

MongoDB.Driver.Core.dll

Represents a map-reduce operation.

[Obsolete("Use Aggregation pipeline instead.")]
public class MapReduceOperation<TResult> : MapReduceOperationBase, IReadOperation<IAsyncCursor<TResult>>

Type Parameters

TResult

The type of the result.

Inheritance

object

MapReduceOperationBase

MapReduceOperation<TResult>

Implements

IReadOperation<IAsyncCursor<TResult>>

Inherited Members

MapReduceOperationBase.Collation

MapReduceOperationBase.CollectionNamespace

MapReduceOperationBase.Filter

MapReduceOperationBase.FinalizeFunction

MapReduceOperationBase.JavaScriptMode

MapReduceOperationBase.Limit

MapReduceOperationBase.MapFunction

MapReduceOperationBase.MaxTime

MapReduceOperationBase.MessageEncoderSettings

MapReduceOperationBase.ReduceFunction

MapReduceOperationBase.Scope

MapReduceOperationBase.Sort

MapReduceOperationBase.Verbose

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Extension Methods

OperationExtensionMethods.ExecuteAsync<TResult>(IReadOperation<TResult>, IChannelSourceHandle, ReadPreference, ICoreSessionHandle, CancellationToken)

OperationExtensionMethods.Execute<TResult>(IReadOperation<TResult>, IChannelSourceHandle, ReadPreference, ICoreSessionHandle, CancellationToken)

Constructors

MapReduceOperation(CollectionNamespace, BsonJavaScript, BsonJavaScript, IBsonSerializer<TResult>, MessageEncoderSettings)

Initializes a new instance of the MapReduceOperation<TResult> class.

public MapReduceOperation(CollectionNamespace collectionNamespace, BsonJavaScript mapFunction, BsonJavaScript reduceFunction, IBsonSerializer<TResult> resultSerializer, MessageEncoderSettings messageEncoderSettings)

Parameters

collectionNamespace CollectionNamespace

The collection namespace.

mapFunction BsonJavaScript

The map function.

reduceFunction BsonJavaScript

The reduce function.

resultSerializer IBsonSerializer<TResult>

The result serializer.

messageEncoderSettings MessageEncoderSettings

The message encoder settings.

Properties

ReadConcern

Gets or sets the read concern.

public ReadConcern ReadConcern { get; set; }

Property Value

ReadConcern

The read concern.

ResultSerializer

Gets the result serializer.

public IBsonSerializer<TResult> ResultSerializer { get; }

Property Value

IBsonSerializer<TResult>

The result serializer.

Methods

CreateCommand(ICoreSessionHandle, ConnectionDescription)

Creates the command.

protected override BsonDocument CreateCommand(ICoreSessionHandle session, ConnectionDescription connectionDescription)

Parameters

session ICoreSessionHandle

The session.

connectionDescription ConnectionDescription

The connection description.

Returns

BsonDocument

The command.

CreateOutputOptions()

Creates the output options.

protected override BsonDocument CreateOutputOptions()

Returns

BsonDocument

The output options.

Execute(IReadBinding, CancellationToken)

Executes the operation.

public IAsyncCursor<TResult> Execute(IReadBinding binding, CancellationToken cancellationToken)

Parameters

binding IReadBinding

The binding.

cancellationToken CancellationToken

The cancellation token.

Returns

IAsyncCursor<TResult>

The result of the operation.

ExecuteAsync(IReadBinding, CancellationToken)

Executes the operation.

public Task<IAsyncCursor<TResult>> ExecuteAsync(IReadBinding binding, CancellationToken cancellationToken)

Parameters

binding IReadBinding

The binding.

cancellationToken CancellationToken

The cancellation token.

Returns

Task<IAsyncCursor<TResult>>

A Task whose result is the result of the operation.