pipeline static method

List<Map<String, Object>> pipeline(
  1. List<Map<String, Object>> query
)

Creates an aggregation pipeline array.

This is a utility method for creating MongoDB aggregation pipelines. It simply returns a copy of the provided query stages.

query List of aggregation stages

Example:

var pipeline = DQ.pipeline([
  DQ.match([DQ.field('status', 'active')]),
  DQ.group({'_id': null, 'count': DQ.sum('1')})
]);

Implementation

static List<Map<String, Object>> pipeline(
  List<Map<String, Object>> query,
) {
  return [...query];
}