如何在Elasticsearch Java API 8.5中结合时间点与Search After实现分页？

一、单独使用Search After的实现（无PIT） #

你补充的这段代码逻辑方向正确，但需注意核心细节：

• searchAfter需要传入对应排序字段的取值，而非文档ID。因为你指定的排序字段是offerId，所以必须传入上一页最后一条数据的offerId值（如果searchAfterId就是offerId的取值，这段代码是正确的；如果是文档_id，则不符合要求）。
• 正确调用示例：

  // 假设上一页最后一条数据的offerId为lastOfferId
  SearchResponse<Offer> response = elasticsearchClient.search(s -> s
                  .index("offers")
                  .size(PAGE_SIZE)
                  .searchAfter(sa -> sa.value(lastOfferId)) // 传入排序字段实际值
                  .query(query)
                  .sort(new SortOptions.Builder()
                          .field(f-> f.field("offerId").order(SortOrder.Asc))
                          .build())
          ,Offer.class
  );
  

二、结合Point-in-Time（PIT）的分页实现 #

你最初的代码存在两处关键问题，正确实现需遵循以下步骤：

1. 初始化PIT并获取第一页数据 #

首次查询需创建PIT，并保存返回的PIT ID，后续分页必须复用该ID：

// 创建PIT
PointInTimeReference pit = new PointInTimeReference.Builder()
        .keepAlive(new Time.Builder().time("1m").build())
        .build();

// 首次查询，获取第一页数据和PIT ID
SearchResponse<Offer> firstPageResponse = elasticsearchClient.search(s -> s
                .index("offers")
                .pit(pit)
                .size(1000)
                .query(query)
                .sort(f -> f.field("offerId").order(SortOrder.Asc))
        , Offer.class);

// 保存PIT ID，后续分页必须传入
String pitId = firstPageResponse.pitId();
// 获取第一页最后一条数据的排序字段值数组（用于searchAfter）
List<Object> lastSortValues = firstPageResponse.hits().hits().get(firstPageResponse.hits().hits().size() - 1).sort();

2. 后续分页查询（复用PIT + Search After） #

每一页都需要传入之前的PIT ID、续期keep alive，同时传入上一页最后一条数据的排序字段值数组：

// 分页查询示例
SearchResponse<Offer> nextPageResponse = elasticsearchClient.search(s -> s
                .pit(pitBuilder -> pitBuilder
                        .id(pitId) // 复用PIT ID
                        .keepAlive(new Time.Builder().time("1m").build())) // 续期PIT
                .searchAfter(sa -> sa.values(lastSortValues)) // 传入上一页最后一条的排序字段值数组
                .size(1000)
                .query(query)
                .sort(f -> f.field("offerId").order(SortOrder.Asc))
        , Offer.class);

// 更新PIT ID（每次查询返回的PIT ID可能变化，需替换）
pitId = nextPageResponse.pitId();
// 更新下一页的searchAfter值
if (!nextPageResponse.hits().hits().isEmpty()) {
    lastSortValues = nextPageResponse.hits().hits().get(nextPageResponse.hits().hits().size() - 1).sort();
}

3. 分页结束后关闭PIT #

使用完PIT必须主动关闭，避免资源泄漏：

elasticsearchClient.deletePointInTime(d -> d.id(pitId));

关键注意事项 #

• PIT生命周期：每次分页查询必须续期keepAlive，否则PIT会过期失效；分页完成后一定要调用deletePointInTime清理。
• Search After参数：无论是否结合PIT，searchAfter都需要传入排序字段的取值数组，数组顺序要和指定的排序字段顺序完全一致（多排序字段需按顺序传入对应值）。
• PIT ID更新：每次查询返回的pitId可能会更新，必须用新ID进行下一次查询。

内容的提问来源于stack exchange，提问作者maudderung