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

ThreadPool.estimatedTimeInMillisCounter介绍

暂无

代码示例

代码示例来源：origin: org.elasticsearch/elasticsearch

private DefaultSearchContext createSearchContext(ShardSearchRequest request, TimeValue timeout,
                         boolean assertAsyncActions, String source)
    throws IOException {
  IndexService indexService = indicesService.indexServiceSafe(request.shardId().getIndex());
  IndexShard indexShard = indexService.getShard(request.shardId().getId());
  SearchShardTarget shardTarget = new SearchShardTarget(clusterService.localNode().getId(),
      indexShard.shardId(), request.getClusterAlias(), OriginalIndices.NONE);
  Engine.Searcher engineSearcher = indexShard.acquireSearcher(source);
  final DefaultSearchContext searchContext = new DefaultSearchContext(idGenerator.incrementAndGet(), request, shardTarget,
    engineSearcher, clusterService, indexService, indexShard, bigArrays, threadPool.estimatedTimeInMillisCounter(), timeout,
    fetchPhase, request.getClusterAlias(), clusterService.state().nodes().getMinNodeVersion());
  boolean success = false;
  try {
    // we clone the query shard context here just for rewriting otherwise we
    // might end up with incorrect state since we are using now() or script services
    // during rewrite and normalized / evaluate templates etc.
    QueryShardContext context = new QueryShardContext(searchContext.getQueryShardContext());
    Rewriteable.rewrite(request.getRewriteable(), context, assertAsyncActions);
    assert searchContext.getQueryShardContext().isCachable();
    success = true;
  } finally {
    if (success == false) {
      IOUtils.closeWhileHandlingException(searchContext);
    }
  }
  return searchContext;
}

代码示例来源：origin: com.strapdata.elasticsearch/elasticsearch

public DefaultSearchContext createSearchContext(ShardSearchRequest request, TimeValue timeout, @Nullable Engine.Searcher searcher)
  throws IOException {
  IndexService indexService = indicesService.indexServiceSafe(request.shardId().getIndex());
  //IndexShard indexShard = indexService.getShard(request.shardId().getId());
  IndexShard indexShard = indexService.getShard(0);
  SearchShardTarget shardTarget = new SearchShardTarget(clusterService.localNode().getId(),
      indexShard.shardId(), null, OriginalIndices.NONE);
  
  if (indexService.isTokenRangesBitsetCacheEnabled())
    TokenRangesSearcherWrapper.current(request);
  
  Engine.Searcher engineSearcher = searcher == null ? indexShard.acquireSearcher("search") : searcher;
  final DefaultSearchContext searchContext = new DefaultSearchContext(idGenerator.incrementAndGet(), request, shardTarget,
    engineSearcher, indexService, indexShard, bigArrays, threadPool.estimatedTimeInMillisCounter(), timeout, fetchPhase);
  boolean success = false;
  try {
    // we clone the query shard context here just for rewriting otherwise we
    // might end up with incorrect state since we are using now() or script services
    // during rewrite and normalized / evaluate templates etc.
    request.rewrite(new QueryShardContext(searchContext.getQueryShardContext()));
    assert searchContext.getQueryShardContext().isCachable();
    success = true;
  } finally {
    if (success == false) {
      IOUtils.closeWhileHandlingException(searchContext);
    }
  }
  return searchContext;
}

代码示例来源：origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.elasticsearch

private DefaultSearchContext createSearchContext(ShardSearchRequest request, TimeValue timeout,
                         boolean assertAsyncActions)
    throws IOException {
  IndexService indexService = indicesService.indexServiceSafe(request.shardId().getIndex());
  IndexShard indexShard = indexService.getShard(request.shardId().getId());
  SearchShardTarget shardTarget = new SearchShardTarget(clusterService.localNode().getId(),
      indexShard.shardId(), request.getClusterAlias(), OriginalIndices.NONE);
  Engine.Searcher engineSearcher = indexShard.acquireSearcher("search");
  final DefaultSearchContext searchContext = new DefaultSearchContext(idGenerator.incrementAndGet(), request, shardTarget,
    engineSearcher, clusterService, indexService, indexShard, bigArrays, threadPool.estimatedTimeInMillisCounter(), timeout,
    fetchPhase, request.getClusterAlias(), clusterService.state().nodes().getMinNodeVersion());
  boolean success = false;
  try {
    // we clone the query shard context here just for rewriting otherwise we
    // might end up with incorrect state since we are using now() or script services
    // during rewrite and normalized / evaluate templates etc.
    QueryShardContext context = new QueryShardContext(searchContext.getQueryShardContext());
    Rewriteable.rewrite(request.getRewriteable(), context, assertAsyncActions);
    assert searchContext.getQueryShardContext().isCachable();
    success = true;
  } finally {
    if (success == false) {
      IOUtils.closeWhileHandlingException(searchContext);
    }
  }
  return searchContext;
}

代码示例来源：origin: sirensolutions/siren-join

pageCacheRecycler, bigArrays, threadPool.estimatedTimeInMillisCounter(), parseFieldMatcher,
 SearchService.NO_TIMEOUT);
SearchContext.setCurrent(context);

代码示例来源：origin: harbby/presto-connectors

new ShardSearchLocalRequest(request.types(), request.nowInMillis(), request.filteringAliases()),
    null, searcher, indexService, indexShard,
    scriptService, pageCacheRecycler, bigArrays, threadPool.estimatedTimeInMillisCounter(), parseFieldMatcher,
    SearchService.NO_TIMEOUT
);

代码示例来源：origin: harbby/presto-connectors

DefaultSearchContext context = new DefaultSearchContext(idGenerator.incrementAndGet(), request, shardTarget, engineSearcher, indexService, indexShard, scriptService, pageCacheRecycler, bigArrays, threadPool.estimatedTimeInMillisCounter(), parseFieldMatcher, defaultSearchTimeout);
SearchContext.setCurrent(context);
try {

代码示例来源：origin: yakaz/elasticsearch-action-updatebyquery

shardSearchRequest,
    null, indexShard.acquireSearcher("update_by_query"), indexService, indexShard,
    scriptService, cacheRecycler, pageCacheRecycler, bigArrays, threadPool.estimatedTimeInMillisCounter()
);
SearchContext.setCurrent(searchContext);

代码示例来源：origin: harbby/presto-connectors

null, result.searcher(), indexService, indexShard,
    scriptService, pageCacheRecycler,
    bigArrays, threadPool.estimatedTimeInMillisCounter(), parseFieldMatcher,
    SearchService.NO_TIMEOUT
);

代码示例来源：origin: apache/servicemix-bundles

engineSearcher, clusterService, indexService, indexShard, bigArrays, threadPool.estimatedTimeInMillisCounter(), timeout,
  fetchPhase, request.getClusterAlias(), clusterService.state().nodes().getMinNodeVersion());
boolean success = false;

代码示例来源：origin: harbby/presto-connectors

new ShardSearchLocalRequest(request.types(), request.nowInMillis(), request.filteringAliases()),
    shardTarget, indexShard.acquireSearcher("exists"), indexService, indexShard,
    scriptService, pageCacheRecycler, bigArrays, threadPool.estimatedTimeInMillisCounter(), parseFieldMatcher,
    SearchService.NO_TIMEOUT
);