aggregate

open override fun aggregate(query: AggregationQuery): Flux<ObjectNode>