栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 面试经验 > 面试问答

使用Java API从Elasticsearch获取所有记录

面试问答 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

使用Java API从Elasticsearch获取所有记录

是的,您可以使用Java客户端也支持的滚动API来实现。

您可以这样做:

Client client;try {    client = TransportClient.builder().build(). addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("localhost"), 9300));    QueryBuilder qb = QueryBuilders.boolQuery().mustNot(QueryBuilders.termQuery("user_agent", ""));    SearchResponse scrollResp = client.prepareSearch("demo_risk_data")        .addSort(SortParseElement.DOC_FIELD_NAME, SortOrder.ASC)        .setScroll(new Timevalue(60000))        .setQuery(qb)        .setSize(100).execute().actionGet();    //Scroll until no hits are returned    while (true) {        //Break condition: No hits are returned        if (scrollResp.getHits().getHits().length == 0) { break;        }        // otherwise read results        for (SearchHit hit : scrollResp.getHits().getHits()) { JSonObject value = new JSonObject(searchData.getSource()); System.out.println(value.toString());        }        // prepare next query        scrollResp = client.prepareSearchScroll(scrollResp.getScrollId()).setScroll(new Timevalue(60000)).execute().actionGet();    }}


转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/392001.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号