Jest scroll 조회
7749 단어 Elasticsearch
@Test
public void testSerialScroll() throws IOException {
BoolQueryBuilder builder = QueryBuilders.boolQuery();
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder().size(SCROLL_SEARCH_SIZE);
searchSourceBuilder.query(builder);
Search search = new Search
.Builder(searchSourceBuilder.toString())
.addIndex(indexName)
.addType(typeName)
.addSourceIncludePattern("open_id")
.setParameter(Parameters.SCROLL, "10m")
.build();
int sum = 0, loop = 0;
JestResult result = jestClient.execute(search);
while(result.isSucceeded()
&& result.getSourceAsObjectList(Map.class).size() > 0) {
List<Map> record = result.getSourceAsObjectList(Map.class);
sum += record.size();
System.out.println("currentLoopCount：" + (++loop) + ", queryResult：" + record.size() + ", total：" + sum);
String scrollId = result.getJsonObject().get("_scroll_id").getAsString();
SearchScroll scroll = new SearchScroll.Builder(scrollId, "10m").build();
result = jestClient.execute(scroll);
}
}
이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:
Embulk를 사용하여 ElasticCloud로 보내기Embulk에서 ElasticCloud에 보낼 수 있을까라고 생각비망록도 겸해 기술을 남깁니다 Embulk 설치 ElasticCloud (14 일 체험판) brew라면 아래 명령 입력 파일 만들기 파일 내용 seed...
텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.
좋은 웹페이지 즐겨찾기
