我试图在最短的时间内从Elasticsearch(Version-6.4.2)中获取大量数据记录。
为此,我使用多线程在单独的线程中运行每个 slice 滚动。
示例:我的查询有3个 slice ,因此:
thread 1 - slice id 0
thread 2 - slice id 1
thread 3 - slice id 2
但是,当尝试从ID为1和2的 slice 获取结果时,它将返回0次匹配。
我正在尝试
RestHighLevelClient#search()
public SearchResponse GetResponse(Integer sliceCount, Integer totalSlice, Integer searchSize, String[] identifiers ) throws IOException
{
SliceBuilder sliceBuilder = new SliceBuilder(sliceCount, totalSlice);
SearchSourceBuilder slicedSource = new SearchSourceBuilder().slice(sliceBuilder);
slicedSource = slicedSource
.query(QueryBuilders.boolQuery()
.must(QueryBuilders.termsQuery("_id", identifiers)));
return client.search(
new SearchRequest()
.indices("indexname")
.types("type")
.scroll("scrolltime")
.source(slicedSource)
);
}
最佳答案
您需要重用SearchSourceBuilder,而不是为每个线程创建它。
请引用:https://github.com/elastic/elasticsearch/issues/24766