Class representing a MongoDB aggregation pipeline. More...

#include <pipeline.hpp>

Public Member Functions
	pipeline ()
	Creates a new aggregation pipeline. More...

	pipeline (pipeline &&) noexcept
	Move constructs a pipeline.

pipeline &	operator= (pipeline &&) noexcept
	Move assigns a pipeline.

	~pipeline ()
	Destroys a pipeline.

pipeline &	add_fields (bsoncxx::document::view_or_value fields_to_add)
	Adds new fields to documents. More...

pipeline &	bucket (bsoncxx::document::view_or_value bucket_args)
	Categorizes documents into groups, called buckets, based on a specified expression and bucket boundaries. More...

pipeline &	bucket_auto (bsoncxx::document::view_or_value bucket_auto_args)
	Categorizes documents into a specific number of groups, called buckets, based on a specified expression. More...

pipeline &	coll_stats (bsoncxx::document::view_or_value coll_stats_args=bsoncxx::document::view{})
	Returns statistics regarding a collection or view. More...

pipeline &	count (std::string field)
	Returns a document containing a count of the number of documents input to the stage. More...

pipeline &	facet (bsoncxx::document::view_or_value facet_args)
	Processes multiple aggregation pipelines within a single stage on the same set of input documents. More...

pipeline &	geo_near (bsoncxx::document::view_or_value geo_near_args)
	Outputs documents in order of nearest to farthest from a specified point. More...

pipeline &	graph_lookup (bsoncxx::document::view_or_value graph_lookup_args)
	Performs a recursive search on a collection. More...

pipeline &	group (bsoncxx::document::view_or_value group_args)
	Groups documents by some specified expression and outputs to the next stage a document for each distinct grouping. More...

pipeline &	index_stats ()
	Returns statistics regarding the use of each index for the collection. More...

pipeline &	limit (std::int32_t limit)
	Limits the number of documents passed to the next stage in the pipeline. More...

pipeline &	lookup (bsoncxx::document::view_or_value lookup_args)
	Performs a left outer join to an unsharded collection in the same database to filter in documents from the "joined" collection for processing. More...

pipeline &	match (bsoncxx::document::view_or_value filter)
	Filters the documents. More...

pipeline &	out (std::string collection_name)
	Takes documents returned by the aggregation pipeline and writes them to a specified collection. More...

pipeline &	project (bsoncxx::document::view_or_value projection)
	Projects a subset of the fields in the documents to the next stage of the pipeline. More...

pipeline &	redact (bsoncxx::document::view_or_value restrictions)
	Restricts the contents of the documents based on information stored in the documents themselves. More...

pipeline &	replace_root (bsoncxx::document::view_or_value replace_root_args)
	Promotes a specified document to the top level and replaces all other fields. More...

pipeline &	sample (std::int32_t size)
	Randomly selects the specified number of documents that pass into the stage and passes the remaining documents to the next stage in the pipeline. More...

pipeline &	skip (std::int32_t docs_to_skip)
	Skips over the specified number of documents that pass into the stage and passes the remaining documents to the next stage in the pipeline. More...

pipeline &	sort (bsoncxx::document::view_or_value ordering)
	Sorts all input documents and returns them to the pipeline in sorted order. More...

pipeline &	sort_by_count (bsoncxx::document::view_or_value field_expression)
	Groups incoming documents based on the value of a specified expression, then computes the count of documents in each distinct group. More...

pipeline &	sort_by_count (std::string field_expression)
	Groups incoming documents based on the value of a specified expression, then computes the count of documents in each distinct group. More...

pipeline &	unwind (bsoncxx::document::view_or_value unwind_args)
	Deconstructs an array field from the input documents to output a document for each element. More...

pipeline &	unwind (std::string field_name)
	Deconstructs an array field from the input documents to output a document for each element. More...

bsoncxx::array::view	view_array () const

MONGOCXX_DEPRECATED bsoncxx::document::view	view () const

Detailed Description

Class representing a MongoDB aggregation pipeline.

Constructor & Destructor Documentation

mongocxx::pipeline::pipeline ( )

Creates a new aggregation pipeline.

See also: https://docs.mongodb.com/master/core/aggregation-pipeline/

Member Function Documentation

pipeline& mongocxx::pipeline::add_fields ( bsoncxx::document::view_or_value fields_to_add )

Adds new fields to documents.

See also: https://docs.mongodb.com/master/reference/operator/aggregation/addFields/

Parameters

fields_to_add A document specifying the fields to add. For each field specified in this parameter, a corresponding field will be added to the documents, where the value of the added field is the result of evaluating the specified expression.

pipeline& mongocxx::pipeline::bucket ( bsoncxx::document::view_or_value bucket_args )

Categorizes documents into groups, called buckets, based on a specified expression and bucket boundaries.

See also: https://docs.mongodb.com/master/reference/operator/aggregation/bucket/

Parameters

bucket_args The specification for the bucket operation. The required fields groupBy and boundaries must be included.

pipeline& mongocxx::pipeline::bucket_auto ( bsoncxx::document::view_or_value bucket_auto_args )

Categorizes documents into a specific number of groups, called buckets, based on a specified expression.

Bucket boundaries are automatically determined in an attempt to evenly distribute the documents into the specified number of buckets.

See also: https://docs.mongodb.com/master/reference/operator/aggregation/bucketAuto/

Parameters

bucket_auto_args The specification for the bucket_auto operation. This required fields groupBy and buckets must be included.

pipeline& mongocxx::pipeline::coll_stats ( bsoncxx::document::view_or_value coll_stats_args = bsoncxx::document::view{} )

Returns statistics regarding a collection or view.

See also: https://docs.mongodb.com/master/reference/operator/aggregation/collStats/

Parameters

coll_stats_args The specification for the coll_stats operation. See link above for a list of valid options.

pipeline& mongocxx::pipeline::count ( std::string field )

Returns a document containing a count of the number of documents input to the stage.

See also: https://docs.mongodb.com/master/reference/operator/aggregation/count/

Parameters

field Name of the field for the count to be written to.

pipeline& mongocxx::pipeline::facet ( bsoncxx::document::view_or_value facet_args )

Processes multiple aggregation pipelines within a single stage on the same set of input documents.

See also: https://docs.mongodb.com/master/reference/operator/aggregation/facet/

Parameters

facet_args The specification for the facet operation. Each field in the the provided document should specify an aggregation pipeline, as an array.

pipeline& mongocxx::pipeline::geo_near ( bsoncxx::document::view_or_value geo_near_args )

Outputs documents in order of nearest to farthest from a specified point.

See also: https://docs.mongodb.com/master/reference/operator/aggregation/geoNear/

Parameters

geo_near_args The specification for the geo_near operation. The required fields near and distanceField must be included.

pipeline& mongocxx::pipeline::graph_lookup ( bsoncxx::document::view_or_value graph_lookup_args )

Performs a recursive search on a collection.

See also: https://docs.mongodb.com/master/reference/operator/aggregation/graphLookup/

Parameters

graph_lookup_args The specification for the graph_lookup operation. The required fields from, connectFromField, startWith, connectToField, and as must be included.

pipeline& mongocxx::pipeline::group ( bsoncxx::document::view_or_value group_args )

Groups documents by some specified expression and outputs to the next stage a document for each distinct grouping.

The output documents contain an _id field which contains the the distinct key for that group. The output documents can also contain computed fields that hold the values of some accumulator expression grouped by the group's _id field.

Note: group does not order output documents.

See also: https://docs.mongodb.com/master/reference/operator/aggregation/group/

Parameters

group_args The specification for the group operation. The required field _id must be included.

pipeline& mongocxx::pipeline::index_stats ( )

Returns statistics regarding the use of each index for the collection.

See also: https://docs.mongodb.com/master/reference/operator/aggregation/indexStats/

pipeline& mongocxx::pipeline::limit ( std::int32_t limit )

Limits the number of documents passed to the next stage in the pipeline.

See also: https://docs.mongodb.com/master/reference/operator/aggregation/limit/

Parameters

limit The number of documents to which output should be limited.

pipeline& mongocxx::pipeline::lookup ( bsoncxx::document::view_or_value lookup_args )

Performs a left outer join to an unsharded collection in the same database to filter in documents from the "joined" collection for processing.

See also: https://docs.mongodb.com/master/reference/operator/aggregation/lookup/

Parameters

lookup_args The specification for the lookup operation. The required fields from, localField, foreignField, and as must be included.

pipeline& mongocxx::pipeline::match ( bsoncxx::document::view_or_value filter )

Filters the documents.

Only the documents that match the condition(s) specified by the filter will continue to the next pipeline stage.

See also: https://docs.mongodb.com/master/reference/operator/aggregation/match/

Parameters

filter The filter.

pipeline& mongocxx::pipeline::out ( std::string collection_name )

Takes documents returned by the aggregation pipeline and writes them to a specified collection.

This stage must be the last stage in the pipeline. The out operator lets the aggregation framework return result sets of any size.

See also: https://docs.mongodb.com/master/reference/operator/aggregation/out/

Parameters

collection_name The name of the collection where the output documents should go.

pipeline& mongocxx::pipeline::project ( bsoncxx::document::view_or_value projection )

Projects a subset of the fields in the documents to the next stage of the pipeline.

See also: https://docs.mongodb.com/master/reference/operator/aggregation/project/

Parameters

projection The projection specification.

pipeline& mongocxx::pipeline::redact ( bsoncxx::document::view_or_value restrictions )

Restricts the contents of the documents based on information stored in the documents themselves.

See also: https://docs.mongodb.com/master/reference/operator/aggregation/redact/

Parameters

restrictions The document restrictions.

pipeline& mongocxx::pipeline::replace_root ( bsoncxx::document::view_or_value replace_root_args )

Promotes a specified document to the top level and replaces all other fields.

See also: https://docs.mongodb.com/master/reference/operator/aggregation/replaceRoot/

Parameters

replace_root_args The specification for the replace_root operation. The required field newRoot must be included.

pipeline& mongocxx::pipeline::sample ( std::int32_t size )

Randomly selects the specified number of documents that pass into the stage and passes the remaining documents to the next stage in the pipeline.

See also: https://docs.mongodb.com/master/reference/operator/aggregation/sample/

Parameters

size	The number of input documents to select.

pipeline& mongocxx::pipeline::skip ( std::int32_t docs_to_skip )

Skips over the specified number of documents that pass into the stage and passes the remaining documents to the next stage in the pipeline.

See also: https://docs.mongodb.com/master/reference/operator/aggregation/skip/

Parameters

docs_to_skip The number of input documents to skip.

pipeline& mongocxx::pipeline::sort ( bsoncxx::document::view_or_value ordering )

Sorts all input documents and returns them to the pipeline in sorted order.

See also: https://docs.mongodb.com/master/reference/operator/aggregation/sort/

Parameters

ordering Document specifying the ordering by which the documents are sorted.

pipeline& mongocxx::pipeline::sort_by_count ( bsoncxx::document::view_or_value field_expression )

Groups incoming documents based on the value of a specified expression, then computes the count of documents in each distinct group.

See also: https://docs.mongodb.com/master/reference/operator/aggregation/sortByCount/

Parameters

field_expression The expression to group by, as an object. The expression can not evaluate to an object.

Note: This overload of sort_by_count() is intended to be used when the desired sort is over a grouping of the result of a complex expression computed from the input documents.

pipeline& mongocxx::pipeline::sort_by_count ( std::string field_expression )

Groups incoming documents based on the value of a specified expression, then computes the count of documents in each distinct group.

See also: https://docs.mongodb.com/master/reference/operator/aggregation/sortByCount/

Parameters

field_expression The expression to group by, as a string. To specify a field path, prefix the field path with a dollar sign ($).

Note: This overload of sort_by_count() is intended to be used when the desired sort is over a grouping of the value of a particular element in the input documents.

pipeline& mongocxx::pipeline::unwind ( bsoncxx::document::view_or_value unwind_args )

Deconstructs an array field from the input documents to output a document for each element.

Each output document is an input document with the value of its array field replaced by an element from the unwound array.

See also: https://docs.mongodb.com/master/reference/operator/aggregation/unwind/

Parameters

unwind_args The specification for the unwind operation. The required field must be included.

Note: This overload of unwind() is intended to be used when additional options other than the field name need to be specified.

pipeline& mongocxx::pipeline::unwind ( std::string field_name )

Deconstructs an array field from the input documents to output a document for each element.

Each output document is an input document with the value of its array field replaced by an element from the unwound array.

See also: https://docs.mongodb.com/master/reference/operator/aggregation/unwind/

Parameters

field_name The name of the field to unwind.

Note: This overload of unwind() is intended to be used when no options other than the field name need to be specified.

MONGOCXX_DEPRECATED bsoncxx::document::view mongocxx::pipeline::view ( ) const

Returns: A view of the underlying BSON document this pipeline represents.

Deprecated:: The view_array() method should be used instead of this method.

bsoncxx::array::view mongocxx::pipeline::view_array ( ) const

Returns: A view of the underlying BSON array this pipeline represents.

The documentation for this class was generated from the following file:

src/mongocxx/pipeline.hpp

Public Member Functions

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation