Paging & Sorting

일반 cursor 조회, aggregation page와 stream형 page를 목적에 맞게 선택합니다.

java

executePageStream()

PageStream<E>로 data Flux와 totalCount Mono를 분리합니다.

executeAggregation()

paging data와 count를 모아 Mono<PageResult<E>>로 반환합니다.

executeAggregationPageStream()

aggregation data를 streaming하고 count는 별도 publisher로 유지합니다.

java

동일 값이 많은 필드는 _id를 보조 정렬로 추가

paging 또는 Atlas sequence token에서 동일 score·날짜가 많으면 마지막에 _id 정렬을 추가해야 페이지 경계가 안정적입니다.