class TextQueryReducer<R> extends MergeSortCacheQueryReducer<R> {
    /** */
    private static final long serialVersionUID = 0L;

    /** */
    public TextQueryReducer(final Map<UUID, NodePageStream<R>> pageStreams) {
        super(pageStreams);
    }

    /** {@inheritDoc} */
    @Override protected CompletableFuture<Comparator<NodePage<R>>> pageComparator() {<FILL_FUNCTION_BODY>}
}

        CompletableFuture<Comparator<NodePage<R>>> f = new CompletableFuture<>();

        f.complete((o1, o2) -> -Float.compare(
            ((ScoredCacheEntry<?, ?>)o1.head()).score(), ((ScoredCacheEntry<?, ?>)o2.head()).score()));

        return f;
    
<methods>public boolean hasNextX() throws org.apache.ignite.IgniteCheckedException,public R nextX() throws org.apache.ignite.IgniteCheckedException<variables>private PriorityQueue<NodePage<R>> nodePages,private java.util.UUID pendingNodeId,private static final long serialVersionUID