protected abstract class TransportSearchTypeAction.BaseAsyncAction<FirstResult extends SearchPhaseResult> extends AbstractAsyncAction
Modifier and Type | Field and Description |
---|---|
protected ClusterState |
clusterState |
protected int |
expectedSuccessfulOps |
protected AtomicArray<FirstResult> |
firstResults |
protected ActionListener<SearchResponse> |
listener |
protected DiscoveryNodes |
nodes |
protected SearchRequest |
request |
protected GroupShardsIterator |
shardsIts |
protected org.apache.lucene.search.ScoreDoc[] |
sortedShardList |
protected AtomicInteger |
successfulOps |
protected boolean |
useSlowScroll |
Modifier | Constructor and Description |
---|---|
protected |
BaseAsyncAction(SearchRequest request,
ActionListener<SearchResponse> listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
addShardFailure(int shardIndex,
SearchShardTarget shardTarget,
Throwable t) |
protected ShardSearchFailure[] |
buildShardFailures() |
protected ShardFetchSearchRequest |
createFetchRequest(QuerySearchResult queryResult,
AtomicArray.Entry<com.carrotsearch.hppc.IntArrayList> entry,
org.apache.lucene.search.ScoreDoc[] lastEmittedDocPerShard) |
protected abstract String |
firstPhaseName() |
protected abstract void |
moveToSecondPhase() |
protected void |
processFirstPhaseResult(int shardIndex,
ShardRouting shard,
FirstResult result) |
protected void |
releaseIrrelevantSearchContexts(AtomicArray<? extends QuerySearchResultProvider> queryResults,
AtomicArray<com.carrotsearch.hppc.IntArrayList> docIdsToLoad)
Releases shard targets that are not used in the docsIdsToLoad.
|
protected abstract void |
sendExecuteFirstPhase(DiscoveryNode node,
ShardSearchTransportRequest request,
SearchServiceListener<FirstResult> listener) |
void |
start() |
buildTookInMillis, startTime
protected final ActionListener<SearchResponse> listener
protected final GroupShardsIterator shardsIts
protected final SearchRequest request
protected final ClusterState clusterState
protected final DiscoveryNodes nodes
protected final int expectedSuccessfulOps
protected final AtomicInteger successfulOps
protected final AtomicArray<FirstResult extends SearchPhaseResult> firstResults
protected volatile org.apache.lucene.search.ScoreDoc[] sortedShardList
protected final boolean useSlowScroll
protected BaseAsyncAction(SearchRequest request, ActionListener<SearchResponse> listener)
public void start()
protected final ShardSearchFailure[] buildShardFailures()
protected final void addShardFailure(int shardIndex, @Nullable SearchShardTarget shardTarget, Throwable t)
protected void releaseIrrelevantSearchContexts(AtomicArray<? extends QuerySearchResultProvider> queryResults, AtomicArray<com.carrotsearch.hppc.IntArrayList> docIdsToLoad)
protected ShardFetchSearchRequest createFetchRequest(QuerySearchResult queryResult, AtomicArray.Entry<com.carrotsearch.hppc.IntArrayList> entry, org.apache.lucene.search.ScoreDoc[] lastEmittedDocPerShard)
protected abstract void sendExecuteFirstPhase(DiscoveryNode node, ShardSearchTransportRequest request, SearchServiceListener<FirstResult> listener)
protected final void processFirstPhaseResult(int shardIndex, ShardRouting shard, FirstResult result)
protected abstract String firstPhaseName()
Copyright © 2009–2015. All rights reserved.