Class TransportAnalyzeAction
- java.lang.Object
-
- org.elasticsearch.action.support.TransportAction<Request,Response>
-
- org.elasticsearch.action.support.single.shard.TransportSingleShardAction<AnalyzeRequest,AnalyzeResponse>
-
- org.elasticsearch.action.admin.indices.analyze.TransportAnalyzeAction
-
public class TransportAnalyzeAction extends TransportSingleShardAction<AnalyzeRequest,AnalyzeResponse>
Transport action used to execute analyze requests
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classTransportAnalyzeAction.DeferredTokenFilterRegistry-
Nested classes/interfaces inherited from class org.elasticsearch.action.support.single.shard.TransportSingleShardAction
TransportSingleShardAction.InternalRequest
-
-
Field Summary
-
Fields inherited from class org.elasticsearch.action.support.single.shard.TransportSingleShardAction
clusterService, indexNameExpressionResolver, threadPool, transportService
-
Fields inherited from class org.elasticsearch.action.support.TransportAction
actionName, logger, taskManager
-
-
Constructor Summary
Constructors Constructor Description TransportAnalyzeAction(Settings settings, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, IndicesService indicesService, ActionFilters actionFilters, IndexNameExpressionResolver indexNameExpressionResolver, Environment environment)
-
Method Summary
Modifier and Type Method Description static AnalyzeResponseanalyze(AnalyzeRequest request, java.lang.String field, org.apache.lucene.analysis.Analyzer analyzer, IndexAnalyzers indexAnalyzers, AnalysisRegistry analysisRegistry, Environment environment, int maxTokenCount)protected ClusterBlockExceptioncheckRequestBlock(ClusterState state, TransportSingleShardAction.InternalRequest request)protected Writeable.Reader<AnalyzeResponse>getResponseReader()protected booleanresolveIndex(AnalyzeRequest request)protected AnalyzeResponseshardOperation(AnalyzeRequest request, ShardId shardId)protected ShardsIteratorshards(ClusterState state, TransportSingleShardAction.InternalRequest request)Returns the candidate shards to execute the operation on ornullthe execute the operation locally (the node that received the request)-
Methods inherited from class org.elasticsearch.action.support.single.shard.TransportSingleShardAction
asyncShardOperation, checkGlobalBlock, doExecute, getExecutor, isSubAction, resolveRequest
-
Methods inherited from class org.elasticsearch.action.support.TransportAction
execute, execute, execute
-
-
-
-
Constructor Detail
-
TransportAnalyzeAction
@Inject public TransportAnalyzeAction(Settings settings, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, IndicesService indicesService, ActionFilters actionFilters, IndexNameExpressionResolver indexNameExpressionResolver, Environment environment)
-
-
Method Detail
-
getResponseReader
protected Writeable.Reader<AnalyzeResponse> getResponseReader()
- Specified by:
getResponseReaderin classTransportSingleShardAction<AnalyzeRequest,AnalyzeResponse>
-
resolveIndex
protected boolean resolveIndex(AnalyzeRequest request)
- Specified by:
resolveIndexin classTransportSingleShardAction<AnalyzeRequest,AnalyzeResponse>
-
checkRequestBlock
protected ClusterBlockException checkRequestBlock(ClusterState state, TransportSingleShardAction.InternalRequest request)
- Overrides:
checkRequestBlockin classTransportSingleShardAction<AnalyzeRequest,AnalyzeResponse>
-
shards
protected ShardsIterator shards(ClusterState state, TransportSingleShardAction.InternalRequest request)
Description copied from class:TransportSingleShardActionReturns the candidate shards to execute the operation on ornullthe execute the operation locally (the node that received the request)- Specified by:
shardsin classTransportSingleShardAction<AnalyzeRequest,AnalyzeResponse>
-
shardOperation
protected AnalyzeResponse shardOperation(AnalyzeRequest request, ShardId shardId)
- Specified by:
shardOperationin classTransportSingleShardAction<AnalyzeRequest,AnalyzeResponse>
-
analyze
public static AnalyzeResponse analyze(AnalyzeRequest request, java.lang.String field, org.apache.lucene.analysis.Analyzer analyzer, IndexAnalyzers indexAnalyzers, AnalysisRegistry analysisRegistry, Environment environment, int maxTokenCount) throws java.io.IOException
- Throws:
java.io.IOException
-
-