Generic aggregation functions
Apart from map-reduce and aggregation pipeline Mongo Streams supports basic mongodb aggregation functions. Supported
aggregation functions are:
query("key2" >= 3) countquery("key2" >= 3) from ReadPreference.Nearest countquery() countquery() distinct ("key")): ChannelResult[DBCollection, String]| Total for specification BasicAggregationSpec | |
|---|---|
| Finished in | 1 second, 765 ms |
| Results | 3 examples, 0 failure, 0 error |