BasicAggregationSpec

BasicAggregationSpec

Generic aggregation functions

Apart from map-reduce and aggregation pipeline Mongo Streams supports basic mongodb aggregation functions. Supported
aggregation functions are:

  • count of document matching supplied query
 query("key2" >= 3) count
  • count of document with supplied query and read preference: query("key2" >= 3) from ReadPreference.Nearest count
  • count of all documents
 query() count
  • getting distinct values for supplied key
 query() distinct ("key")): ChannelResult[DBCollection, String]

Total for specification BasicAggregationSpec
Finished in1 second, 765 ms
Results3 examples, 0 failure, 0 error