本文整理了Java中org.elasticsearch.client.transport.TransportClient.prepareSearchScroll()方法的一些代码示例，展示了TransportClient.prepareSearchScroll()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。TransportClient.prepareSearchScroll()方法的具体详情如下：
包路径：org.elasticsearch.client.transport.TransportClient
类名称：TransportClient
方法名：prepareSearchScroll

TransportClient.prepareSearchScroll介绍

暂无

代码示例

代码示例来源：origin: prestodb/presto

public SearchScrollRequestBuilder prepareSearchScroll(String scrollId)
{
  return client.prepareSearchScroll(scrollId)
      .setScroll(new TimeValue(scrollTimeout.toMillis()));
}

代码示例来源：origin: floragunncom/search-guard

try {
  tc.threadPool().getThreadContext().putHeader("sg_impersonate_as", "nagilum");
  tc.prepareSearchScroll(scrollId).get();
} finally {
  ctx.close();
try {
  tc.threadPool().getThreadContext().putHeader("sg_impersonate_as", "worf");
  tc.prepareSearchScroll(searchRes.getScrollId()).get(); 
  Assert.fail();
} catch (Exception e) {
  tc.threadPool().getThreadContext().putHeader("sg_impersonate_as", "nagilum");
  searchRes = tc.prepareSearch("starfleet").setTypes("ships").setScroll(TimeValue.timeValueMinutes(5)).get();
  SearchResponse scrollRes = tc.prepareSearchScroll(searchRes.getScrollId()).get();
  Assert.assertEquals(0, scrollRes.getFailedShards());
} finally {

代码示例来源：origin: floragunncom/search-guard

try {
  tc.threadPool().getThreadContext().putHeader("sg_impersonate_as", "nagilum");
  tc.prepareSearchScroll(scrollId).get();
} finally {
  ctx.close();
try {
  tc.threadPool().getThreadContext().putHeader("sg_impersonate_as", "worf");
  tc.prepareSearchScroll(searchRes.getScrollId()).get(); 
  Assert.fail();
} catch (Exception e) {
  tc.threadPool().getThreadContext().putHeader("sg_impersonate_as", "nagilum");
  searchRes = tc.prepareSearch("starfleet").setTypes("ships").setScroll(TimeValue.timeValueMinutes(5)).get();
  SearchResponse scrollRes = tc.prepareSearchScroll(searchRes.getScrollId()).get();
  Assert.assertEquals(0, scrollRes.getFailedShards());
} finally {

代码示例来源：origin: petterobam/database-oop

/**
 * @param scrollId s
 * @return d
 */
public SearchScrollRequestBuilder searchScrollRequest(String scrollId) {
  return client.prepareSearchScroll(scrollId);
}

代码示例来源：origin: fujitsu-pio/io

/**
 * スクロールIDを指定してスクロールサーチを継続する.
 * @param scrollId スクロールID
 * @return 非同期応答
 */
public ActionFuture<SearchResponse> asyncScrollSearch(String scrollId) {
  ActionFuture<SearchResponse> ret = esTransportClient.prepareSearchScroll(scrollId)
      .setScroll(new TimeValue(SCROLL_SEARCH_KEEP_ALIVE_TIME))
      .execute();
  return ret;
}

代码示例来源：origin: apache/streams

.prepareSearchScroll(scrollResp.getScrollId())
.setScroll(scrollTimeout)
.execute()

代码示例来源：origin: ef-labs/vertx-elasticsearch-service

@Override
public void searchScroll(String scrollId, SearchScrollOptions options, Handler<AsyncResult<JsonObject>> resultHandler) {
  SearchScrollRequestBuilder builder = client.prepareSearchScroll(scrollId);
  if (options != null) {
    if (options.getScroll() != null) builder.setScroll(options.getScroll());
  }
  builder.execute(new ActionListener<SearchResponse>() {
    @Override
    public void onResponse(SearchResponse searchResponse) {
      JsonObject json = readResponse(searchResponse);
      resultHandler.handle(Future.succeededFuture(json));
    }
    @Override
    public void onFailure(Throwable t) {
      handleFailure(resultHandler, t);
    }
  });
}

代码示例来源：origin: judasn/Elasticsearch-Tutorial-zh-CN

/**
 * Scroll 获取多个对象
 *
 * @param transportClient
 * @throws IOException
 */
private static void queryByScroll(TransportClient transportClient) throws IOException {
  //setSize 是设置每批查询多少条数据
  SearchResponse searchResponse = transportClient.prepareSearch("product_index").setTypes("product")
      .setQuery(QueryBuilders.termQuery("product_name", "飞利浦"))
      .setScroll(new TimeValue(60000))
      .setSize(3)
      .get();
  int count = 0;
  do {
    for (SearchHit searchHit : searchResponse.getHits().getHits()) {
      //打印查询结果，或者做其他处理
      logger.info("count=" + ++count);
      logger.info(searchHit.getSourceAsString());
    }
    searchResponse = transportClient.prepareSearchScroll(searchResponse.getScrollId()).setScroll(new TimeValue(60000))
        .execute()
        .actionGet();
  } while (searchResponse.getHits().getHits().length != 0);
}

代码示例来源：origin: Yirendai/cicada

allSpans.addAll(spans);
scrollResp = client.prepareSearchScroll(scrollResp.getScrollId()) //
  .setScroll(tv).execute().actionGet();

代码示例来源：origin: petterobam/database-oop

count = scrollResponse.getHits().getTotalHits();
} else {
  scrollResponse = client.prepareSearchScroll(scrollResponse.getScrollId())
      .setScroll(TimeValue.timeValueSeconds(scrollSeconds))
      .execute().actionGet();