вытащить все записи, среди которых value соответствует моему предикату и сделать distinct по полю. Hazelcast позволяет сделать две такие операции но по отдельности:
1.
mapCache.values(predicate)
- достаёт все value соответствующие предикату.
2.
mapCache.aggregate(Aggregators.distinct("city"))
- делает дистинск по полю
Можно ли как-то совместить их? Сравнить 2 результата не канает, т.к. мне нужно сделать дистинкт на результат выборки по предикату.
Hazelcast Jet позволяет.
попробуй Kafka Streams
Обсуждают сегодня