Class AggregateFluentBase<TResult>

Namespace

MongoDB.Driver

Assembly

MongoDB.Driver.dll

Base class for implementors of IAggregateFluent<TResult>.

public abstract class AggregateFluentBase<TResult> : IOrderedAggregateFluent<TResult>, IAggregateFluent<TResult>, IAsyncCursorSource<TResult>

Type Parameters

TResult

The type of the document.

Inheritance

object

AggregateFluentBase<TResult>

Implements

IOrderedAggregateFluent<TResult>

IAggregateFluent<TResult>

IAsyncCursorSource<TResult>

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Extension Methods

IAggregateFluentExtensions.BucketAutoForLinq2<TResult, TValue, TNewResult>(IAggregateFluent<TResult>, Expression<Func<TResult, TValue>>, int, Expression<Func<IGrouping<TValue, TResult>, TNewResult>>, AggregateBucketAutoOptions)

IAggregateFluentExtensions.BucketAuto<TResult, TValue>(IAggregateFluent<TResult>, Expression<Func<TResult, TValue>>, int, AggregateBucketAutoOptions)

IAggregateFluentExtensions.BucketAuto<TResult, TValue, TNewResult>(IAggregateFluent<TResult>, Expression<Func<TResult, TValue>>, int, Expression<Func<IGrouping<AggregateBucketAutoResultId<TValue>, TResult>, TNewResult>>, AggregateBucketAutoOptions)

IAggregateFluentExtensions.Bucket<TResult, TValue>(IAggregateFluent<TResult>, Expression<Func<TResult, TValue>>, IEnumerable<TValue>, AggregateBucketOptions<TValue>)

IAggregateFluentExtensions.Bucket<TResult, TValue, TNewResult>(IAggregateFluent<TResult>, Expression<Func<TResult, TValue>>, IEnumerable<TValue>, Expression<Func<IGrouping<TValue, TResult>, TNewResult>>, AggregateBucketOptions<TValue>)

IAggregateFluentExtensions.Densify<TResult>(IAggregateFluent<TResult>, Expression<Func<TResult, object>>, DensifyRange, IEnumerable<Expression<Func<TResult, object>>>)

IAggregateFluentExtensions.Densify<TResult>(IAggregateFluent<TResult>, Expression<Func<TResult, object>>, DensifyRange, params Expression<Func<TResult, object>>[])

IAggregateFluentExtensions.Facet<TResult>(IAggregateFluent<TResult>, params AggregateFacet<TResult>[])

IAggregateFluentExtensions.Facet<TResult>(IAggregateFluent<TResult>, IEnumerable<AggregateFacet<TResult>>)

IAggregateFluentExtensions.Facet<TResult, TNewResult>(IAggregateFluent<TResult>, params AggregateFacet<TResult>[])

IAggregateFluentExtensions.FirstAsync<TResult>(IAggregateFluent<TResult>, CancellationToken)

IAggregateFluentExtensions.FirstOrDefaultAsync<TResult>(IAggregateFluent<TResult>, CancellationToken)

IAggregateFluentExtensions.FirstOrDefault<TResult>(IAggregateFluent<TResult>, CancellationToken)

IAggregateFluentExtensions.First<TResult>(IAggregateFluent<TResult>, CancellationToken)

IAggregateFluentExtensions.GraphLookup<TResult, TFrom>(IAggregateFluent<TResult>, IMongoCollection<TFrom>, FieldDefinition<TFrom, BsonValue>, FieldDefinition<TFrom, BsonValue>, AggregateExpressionDefinition<TResult, BsonValue>, FieldDefinition<BsonDocument, IEnumerable<BsonDocument>>, FieldDefinition<BsonDocument, int>)

IAggregateFluentExtensions.GraphLookup<TResult, TFrom, TConnectFrom, TConnectTo, TStartWith, TAs, TNewResult>(IAggregateFluent<TResult>, IMongoCollection<TFrom>, FieldDefinition<TFrom, TConnectFrom>, FieldDefinition<TFrom, TConnectTo>, AggregateExpressionDefinition<TResult, TStartWith>, FieldDefinition<TNewResult, TAs>, AggregateGraphLookupOptions<TFrom, TFrom, TNewResult>)

IAggregateFluentExtensions.GraphLookup<TResult, TFrom, TConnectFrom, TConnectTo, TStartWith, TAs, TNewResult>(IAggregateFluent<TResult>, IMongoCollection<TFrom>, Expression<Func<TFrom, TConnectFrom>>, Expression<Func<TFrom, TConnectTo>>, Expression<Func<TResult, TStartWith>>, Expression<Func<TNewResult, TAs>>, AggregateGraphLookupOptions<TFrom, TFrom, TNewResult>)

IAggregateFluentExtensions.GraphLookup<TResult, TFrom, TConnectFrom, TConnectTo, TStartWith, TAsElement, TAs, TNewResult>(IAggregateFluent<TResult>, IMongoCollection<TFrom>, Expression<Func<TFrom, TConnectFrom>>, Expression<Func<TFrom, TConnectTo>>, Expression<Func<TResult, TStartWith>>, Expression<Func<TNewResult, TAs>>, Expression<Func<TAsElement, int>>, AggregateGraphLookupOptions<TFrom, TAsElement, TNewResult>)

IAggregateFluentExtensions.Group<TResult>(IAggregateFluent<TResult>, ProjectionDefinition<TResult, BsonDocument>)

IAggregateFluentExtensions.Group<TResult, TKey, TNewResult>(IAggregateFluent<TResult>, Expression<Func<TResult, TKey>>, Expression<Func<IGrouping<TKey, TResult>, TNewResult>>)

IAggregateFluentExtensions.Lookup<TResult>(IAggregateFluent<TResult>, IMongoCollection<BsonDocument>, BsonDocument, PipelineDefinition<BsonDocument, BsonDocument>, FieldDefinition<BsonDocument, IEnumerable<BsonDocument>>)

IAggregateFluentExtensions.Lookup<TResult>(IAggregateFluent<TResult>, string, FieldDefinition<TResult>, FieldDefinition<BsonDocument>, FieldDefinition<BsonDocument>)

IAggregateFluentExtensions.Lookup<TResult, TForeignDocument, TNewResult>(IAggregateFluent<TResult>, IMongoCollection<TForeignDocument>, Expression<Func<TResult, object>>, Expression<Func<TForeignDocument, object>>, Expression<Func<TNewResult, object>>, AggregateLookupOptions<TForeignDocument, TNewResult>)

IAggregateFluentExtensions.Lookup<TResult, TForeignDocument, TAsElement, TAs, TNewResult>(IAggregateFluent<TResult>, IMongoCollection<TForeignDocument>, BsonDocument, PipelineDefinition<TForeignDocument, TAsElement>, Expression<Func<TNewResult, TAs>>, AggregateLookupOptions<TForeignDocument, TNewResult>)

IAggregateFluentExtensions.Match<TResult>(IAggregateFluent<TResult>, Expression<Func<TResult, bool>>)

IAggregateFluentExtensions.Project<TResult>(IAggregateFluent<TResult>, ProjectionDefinition<TResult, BsonDocument>)

IAggregateFluentExtensions.Project<TResult, TNewResult>(IAggregateFluent<TResult>, Expression<Func<TResult, TNewResult>>)

IAggregateFluentExtensions.ReplaceRoot<TResult, TNewResult>(IAggregateFluent<TResult>, Expression<Func<TResult, TNewResult>>)

IAggregateFluentExtensions.ReplaceWith<TResult, TNewResult>(IAggregateFluent<TResult>, Expression<Func<TResult, TNewResult>>)

IAggregateFluentExtensions.SetWindowFields<TResult, TWindowFields>(IAggregateFluent<TResult>, Expression<Func<ISetWindowFieldsPartition<TResult>, TWindowFields>>)

IAggregateFluentExtensions.SetWindowFields<TResult, TPartitionBy, TWindowFields>(IAggregateFluent<TResult>, Expression<Func<TResult, TPartitionBy>>, SortDefinition<TResult>, Expression<Func<ISetWindowFieldsPartition<TResult>, TWindowFields>>)

IAggregateFluentExtensions.SetWindowFields<TResult, TPartitionBy, TWindowFields>(IAggregateFluent<TResult>, Expression<Func<TResult, TPartitionBy>>, Expression<Func<ISetWindowFieldsPartition<TResult>, TWindowFields>>)

IAggregateFluentExtensions.Set<TResult, TFields>(IAggregateFluent<TResult>, Expression<Func<TResult, TFields>>)

IAggregateFluentExtensions.SingleAsync<TResult>(IAggregateFluent<TResult>, CancellationToken)

IAggregateFluentExtensions.SingleOrDefaultAsync<TResult>(IAggregateFluent<TResult>, CancellationToken)

IAggregateFluentExtensions.SingleOrDefault<TResult>(IAggregateFluent<TResult>, CancellationToken)

IAggregateFluentExtensions.Single<TResult>(IAggregateFluent<TResult>, CancellationToken)

IAggregateFluentExtensions.SortByCount<TResult, TKey>(IAggregateFluent<TResult>, Expression<Func<TResult, TKey>>)

IAggregateFluentExtensions.SortByDescending<TResult>(IAggregateFluent<TResult>, Expression<Func<TResult, object>>)

IAggregateFluentExtensions.SortBy<TResult>(IAggregateFluent<TResult>, Expression<Func<TResult, object>>)

IAggregateFluentExtensions.Unwind<TResult>(IAggregateFluent<TResult>, FieldDefinition<TResult>)

IAggregateFluentExtensions.Unwind<TResult>(IAggregateFluent<TResult>, Expression<Func<TResult, object>>)

IAggregateFluentExtensions.Unwind<TResult, TNewResult>(IAggregateFluent<TResult>, Expression<Func<TResult, object>>, IBsonSerializer<TNewResult>)

IAggregateFluentExtensions.Unwind<TResult, TNewResult>(IAggregateFluent<TResult>, Expression<Func<TResult, object>>, AggregateUnwindOptions<TNewResult>)

IAggregateFluentExtensions.VectorSearch<TResult>(IAggregateFluent<TResult>, Expression<Func<TResult, object>>, QueryVector, int, VectorSearchOptions<TResult>)

IAsyncCursorSourceExtensions.AnyAsync<TDocument>(IAsyncCursorSource<TDocument>, CancellationToken)

IAsyncCursorSourceExtensions.Any<TDocument>(IAsyncCursorSource<TDocument>, CancellationToken)

IAsyncCursorSourceExtensions.FirstAsync<TDocument>(IAsyncCursorSource<TDocument>, CancellationToken)

IAsyncCursorSourceExtensions.FirstOrDefaultAsync<TDocument>(IAsyncCursorSource<TDocument>, CancellationToken)

IAsyncCursorSourceExtensions.FirstOrDefault<TDocument>(IAsyncCursorSource<TDocument>, CancellationToken)

IAsyncCursorSourceExtensions.First<TDocument>(IAsyncCursorSource<TDocument>, CancellationToken)

IAsyncCursorSourceExtensions.ForEachAsync<TDocument>(IAsyncCursorSource<TDocument>, Action<TDocument, int>, CancellationToken)

IAsyncCursorSourceExtensions.ForEachAsync<TDocument>(IAsyncCursorSource<TDocument>, Action<TDocument>, CancellationToken)

IAsyncCursorSourceExtensions.ForEachAsync<TDocument>(IAsyncCursorSource<TDocument>, Func<TDocument, int, Task>, CancellationToken)

IAsyncCursorSourceExtensions.ForEachAsync<TDocument>(IAsyncCursorSource<TDocument>, Func<TDocument, Task>, CancellationToken)

IAsyncCursorSourceExtensions.SingleAsync<TDocument>(IAsyncCursorSource<TDocument>, CancellationToken)

IAsyncCursorSourceExtensions.SingleOrDefaultAsync<TDocument>(IAsyncCursorSource<TDocument>, CancellationToken)

IAsyncCursorSourceExtensions.SingleOrDefault<TDocument>(IAsyncCursorSource<TDocument>, CancellationToken)

IAsyncCursorSourceExtensions.Single<TDocument>(IAsyncCursorSource<TDocument>, CancellationToken)

IAsyncCursorSourceExtensions.ToEnumerable<TDocument>(IAsyncCursorSource<TDocument>, CancellationToken)

IAsyncCursorSourceExtensions.ToListAsync<TDocument>(IAsyncCursorSource<TDocument>, CancellationToken)

IAsyncCursorSourceExtensions.ToList<TDocument>(IAsyncCursorSource<TDocument>, CancellationToken)

IAggregateFluentExtensions.ThenByDescending<TResult>(IOrderedAggregateFluent<TResult>, Expression<Func<TResult, object>>)

IAggregateFluentExtensions.ThenBy<TResult>(IOrderedAggregateFluent<TResult>, Expression<Func<TResult, object>>)

Properties

Database

Gets the database.

Options

Gets the options.

Stages

Gets the stages.

Methods

AppendStage<TNewResult>(PipelineStageDefinition<TResult, TNewResult>)

Appends the stage to the pipeline.

As<TNewResult>(IBsonSerializer<TNewResult>)

Changes the result type of the pipeline.

BucketAuto<TValue>(AggregateExpressionDefinition<TResult, TValue>, int, AggregateBucketAutoOptions)

Appends a $bucketAuto stage to the pipeline.

BucketAuto<TValue, TNewResult>(AggregateExpressionDefinition<TResult, TValue>, int, ProjectionDefinition<TResult, TNewResult>, AggregateBucketAutoOptions)

Appends a $bucketAuto stage to the pipeline with a custom projection.

Bucket<TValue>(AggregateExpressionDefinition<TResult, TValue>, IEnumerable<TValue>, AggregateBucketOptions<TValue>)

Appends a $bucket stage to the pipeline.

Bucket<TValue, TNewResult>(AggregateExpressionDefinition<TResult, TValue>, IEnumerable<TValue>, ProjectionDefinition<TResult, TNewResult>, AggregateBucketOptions<TValue>)

Appends a $bucket stage to the pipeline with a custom projection.

ChangeStream(ChangeStreamStageOptions)

Appends a $changeStream stage to the pipeline. Normally you would prefer to use the Watch method of IMongoCollection<TDocument>. Only use this method if subsequent stages project away the resume token (the _id) or you don't want the resulting cursor to automatically resume.

Count()

Appends a count stage to the pipeline.

Densify(FieldDefinition<TResult>, DensifyRange, params FieldDefinition<TResult>[])

Appends a $densify stage to the pipeline.

Densify(FieldDefinition<TResult>, DensifyRange, IEnumerable<FieldDefinition<TResult>>)

Appends a $densify stage to the pipeline.

Facet<TNewResult>(IEnumerable<AggregateFacet<TResult>>, AggregateFacetOptions<TNewResult>)

Appends a $facet stage to the pipeline.

GraphLookup<TFrom, TConnectFrom, TConnectTo, TStartWith, TAsElement, TAs, TNewResult>(IMongoCollection<TFrom>, FieldDefinition<TFrom, TConnectFrom>, FieldDefinition<TFrom, TConnectTo>, AggregateExpressionDefinition<TResult, TStartWith>, FieldDefinition<TNewResult, TAs>, FieldDefinition<TAsElement, int>, AggregateGraphLookupOptions<TFrom, TAsElement, TNewResult>)

Appends a $graphLookup stage to the pipeline.

Group<TNewResult>(ProjectionDefinition<TResult, TNewResult>)

Appends a group stage to the pipeline.

Limit(long)

Appends a limit stage to the pipeline.

Lookup<TForeignDocument, TNewResult>(string, FieldDefinition<TResult>, FieldDefinition<TForeignDocument>, FieldDefinition<TNewResult>, AggregateLookupOptions<TForeignDocument, TNewResult>)

Appends a lookup stage to the pipeline.

Lookup<TForeignDocument, TAsElement, TAs, TNewResult>(IMongoCollection<TForeignDocument>, BsonDocument, PipelineDefinition<TForeignDocument, TAsElement>, FieldDefinition<TNewResult, TAs>, AggregateLookupOptions<TForeignDocument, TNewResult>)

Appends a lookup stage to the pipeline.

Match(FilterDefinition<TResult>)

Appends a match stage to the pipeline.

MergeAsync<TOutput>(IMongoCollection<TOutput>, MergeStageOptions<TOutput>, CancellationToken)

Appends a merge stage to the pipeline and executes it, and then returns a cursor to read the contents of the output collection.

Merge<TOutput>(IMongoCollection<TOutput>, MergeStageOptions<TOutput>, CancellationToken)

Appends a merge stage to the pipeline and executes it, and then returns a cursor to read the contents of the output collection.

OfType<TNewResult>(IBsonSerializer<TNewResult>)

Appends a match stage to the pipeline that matches derived documents and changes the result type to the derived type.

Out(IMongoCollection<TResult>, TimeSeriesOptions, CancellationToken)

Appends an out stage to the pipeline and executes it, and then returns a cursor to read the contents of the output collection.

Out(IMongoCollection<TResult>, CancellationToken)

Appends an out stage to the pipeline and executes it, and then returns a cursor to read the contents of the output collection.

Out(string, TimeSeriesOptions, CancellationToken)

Appends an out stage to the pipeline and executes it, and then returns a cursor to read the contents of the output collection.

Out(string, CancellationToken)

Appends an out stage to the pipeline and executes it, and then returns a cursor to read the contents of the output collection.

OutAsync(IMongoCollection<TResult>, TimeSeriesOptions, CancellationToken)

Appends an out stage to the pipeline and executes it, and then returns a cursor to read the contents of the output collection.

OutAsync(IMongoCollection<TResult>, CancellationToken)

Appends an out stage to the pipeline and executes it, and then returns a cursor to read the contents of the output collection.

OutAsync(string, TimeSeriesOptions, CancellationToken)

Appends an out stage to the pipeline and executes it, and then returns a cursor to read the contents of the output collection.

OutAsync(string, CancellationToken)

Appends an out stage to the pipeline and executes it, and then returns a cursor to read the contents of the output collection.

Project<TNewResult>(ProjectionDefinition<TResult, TNewResult>)

Appends a project stage to the pipeline.

ReplaceRoot<TNewResult>(AggregateExpressionDefinition<TResult, TNewResult>)

Appends a $replaceRoot stage to the pipeline.

ReplaceWith<TNewResult>(AggregateExpressionDefinition<TResult, TNewResult>)

Appends a $replaceWith stage to the pipeline.

Search(SearchDefinition<TResult>, SearchHighlightOptions<TResult>, string, SearchCountOptions, bool, bool)

Appends a $search stage to the pipeline.

Search(SearchDefinition<TResult>, SearchOptions<TResult>)

Appends a $search stage to the pipeline.

SearchMeta(SearchDefinition<TResult>, string, SearchCountOptions)

Appends a $searchMeta stage to the pipeline.

Set(SetFieldDefinitions<TResult>)

Appends a $set stage to the pipeline.

SetWindowFields<TWindowFields>(AggregateExpressionDefinition<ISetWindowFieldsPartition<TResult>, TWindowFields>)

Appends a $setWindowFields to the pipeline.

SetWindowFields<TPartitionBy, TWindowFields>(AggregateExpressionDefinition<TResult, TPartitionBy>, AggregateExpressionDefinition<ISetWindowFieldsPartition<TResult>, TWindowFields>)

Appends a $setWindowFields to the pipeline.

SetWindowFields<TPartitionBy, TWindowFields>(AggregateExpressionDefinition<TResult, TPartitionBy>, SortDefinition<TResult>, AggregateExpressionDefinition<ISetWindowFieldsPartition<TResult>, TWindowFields>)

Appends a $setWindowFields to the pipeline.

Skip(long)

Appends a skip stage to the pipeline.

Sort(SortDefinition<TResult>)

Appends a sort stage to the pipeline.

SortByCount<TId>(AggregateExpressionDefinition<TResult, TId>)

Appends a sortByCount stage to the pipeline.

ThenBy(SortDefinition<TResult>)

Combines the current sort definition with an additional sort definition.

ToCollection(CancellationToken)

Executes an aggregation pipeline that writes the results to a collection.

ToCollectionAsync(CancellationToken)

Executes an aggregation pipeline that writes the results to a collection.

ToCursor(CancellationToken)

Executes the operation and returns a cursor to the results.

ToCursorAsync(CancellationToken)

Executes the operation and returns a cursor to the results.

UnionWith<TWith>(IMongoCollection<TWith>, PipelineDefinition<TWith, TResult>)

Appends an $unionWith stage to the pipeline.

Unwind<TNewResult>(FieldDefinition<TResult>, IBsonSerializer<TNewResult>)

Appends an unwind stage to the pipeline.

Unwind<TNewResult>(FieldDefinition<TResult>, AggregateUnwindOptions<TNewResult>)

Appends an unwind stage to the pipeline.

VectorSearch(FieldDefinition<TResult>, QueryVector, int, VectorSearchOptions<TResult>)

Appends a vector search stage.