es7.3.1-java api 查詢

BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery().must(QueryBuilders.rangeQuery("request_time").gte(startTime).lt(endTime));
String[] includes = new String[]{""};
SearchResponse response = getResponse(es_index_ss_cardresponse_operate, boolQueryBuilder, includes,
        null, 10000);
if (null != response) {
    SearchHit[] searchHit = response.getHits().getHits();
    cfEsResHandleService.quota12(numArr, searchHit, tableList, toKafka);

    String scrollId = response.getScrollId();
    while (null != searchHit && searchHit.length > 0) {
        response = getResponse(es_index_ss_cardresponse_operate, null, includes,
                scrollId, 10000);
        searchHit = response.getHits().getHits();
        cfEsResHandleService.quota12(numArr, searchHit, tableList, toKafka);
    }

    //清除滾屏
    boolean success = clearScroll(scrollId);
    if (success) {
        LOGGER.info("清除滾屏成功！");
    } else {
        LOGGER.info("清除滾屏失敗！");
    }
}

/**
 * 獲取es查詢結果
 *
 * @param esIndex
 * @param boolQueryBuilder
 * @param scrollId
 * @param size
 * @return
 */
public SearchResponse getResponse(String esIndex, BoolQueryBuilder boolQueryBuilder, String[] includes, String
        scrollId, int size) {
    SearchResponse response = null;
    try {
        RestHighLevelClient restHighLevelClient = esClient.getClient();
        if (null != boolQueryBuilder && null == scrollId) {
            SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
            searchSourceBuilder.query(boolQueryBuilder);
            searchSourceBuilder.explain(false);//大於查詢結果不打分
            searchSourceBuilder.size(size);
            //傳了查詢過濾字段才過濾結果，否則取全部字段
            if (null != includes && includes.length > 0) {
                //設置要獲取的字段和不要獲取的字段
                searchSourceBuilder.fetchSource(includes, new String[]{});
            }
            SearchRequest searchRequest = new SearchRequest().indices(esIndex + "_" + index_suffix).source(searchSourceBuilder);
            //size 為0不能使用scroll，否則會拋異常
            if (size != 0) {
                searchRequest.scroll(TimeValue.MINUS_ONE);
            }
            response = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);
        }

        if (null == boolQueryBuilder && null != scrollId) {
            SearchScrollRequest searchScrollRequest = new SearchScrollRequest(scrollId).scroll(TimeValue.MINUS_ONE);
            response = restHighLevelClient.scroll(searchScrollRequest, RequestOptions.DEFAULT);

        }
    } catch (IOException e) {
        e.printStackTrace();
        return null;
    }
    return response;
}