PagingPréparer des problèmes avec comparateur

Question

PagingPredicate lorsqu'il est appliqué sur IMap ne pas trier sur la collection complète. C'est seulement le tri pour le pageSize donné. Mais je veux que la collection soit triée d'abord et ensuite appliquer la pagination et fournir le résultat.

J'utilise ci-dessous constructeur:

PagingPredicate pagingPredicate = new PagingPredicate(predicate, comparator, 100); 
Collection<Map<String, Object>> pagingResults = data.values(pagingPredicate); 

Les données qui sont dans le cache est presque 90000 enregistrements. J'ai besoin des 100 premiers enregistrements de la collection complète triée mais il applique le tri sur les 100 premiers enregistrements dans IMap

S'il vous plaît, pouvez-vous aider à résoudre ce problème?

version Hazelcast - 3.7.3

Answer 1

PagingPredicate trie interne tous les enregistrements. Hazelcast garde les enregistrements partitionnés. Le tri s'effectue sur chaque partition et les 100 premiers enregistrements sont sélectionnés. Donc, pour 271 (par défaut) partition, vous aurez 27100 enregistrements sur votre local. Ces enregistrements seront fusionnés et triés à nouveau, et les 100 premiers enregistrements qui en résulteront seront renvoyés.

Par exemple, si vous avez des enregistrements 1-90000, paging-predicate doit renvoyer 1-100 pour pagingSize = 100.