Class TransportAnalyzeAction
- java.lang.Object
-
- org.elasticsearch.action.support.TransportAction<Request,Response>
-
- org.elasticsearch.action.support.single.shard.TransportSingleShardAction<AnalyzeAction.Request,AnalyzeAction.Response>
-
- org.elasticsearch.action.admin.indices.analyze.TransportAnalyzeAction
-
public class TransportAnalyzeAction extends TransportSingleShardAction<AnalyzeAction.Request,AnalyzeAction.Response>
Transport action used to execute analyze requests
-
-
Nested Class Summary
-
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)
-
Method Summary
Modifier and Type Method Description static AnalyzeAction.Response
analyze(AnalyzeAction.Request request, AnalysisRegistry analysisRegistry, IndexService indexService, int maxTokenCount)
protected ClusterBlockException
checkRequestBlock(ClusterState state, TransportSingleShardAction.InternalRequest request)
protected Writeable.Reader<AnalyzeAction.Response>
getResponseReader()
protected boolean
resolveIndex(AnalyzeAction.Request request)
protected AnalyzeAction.Response
shardOperation(AnalyzeAction.Request request, ShardId shardId)
protected ShardsIterator
shards(ClusterState state, TransportSingleShardAction.InternalRequest request)
Returns the candidate shards to execute the operation on ornull
the 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)
-
-
Method Detail
-
getResponseReader
protected Writeable.Reader<AnalyzeAction.Response> getResponseReader()
- Specified by:
getResponseReader
in classTransportSingleShardAction<AnalyzeAction.Request,AnalyzeAction.Response>
-
resolveIndex
protected boolean resolveIndex(AnalyzeAction.Request request)
- Specified by:
resolveIndex
in classTransportSingleShardAction<AnalyzeAction.Request,AnalyzeAction.Response>
-
checkRequestBlock
protected ClusterBlockException checkRequestBlock(ClusterState state, TransportSingleShardAction.InternalRequest request)
- Overrides:
checkRequestBlock
in classTransportSingleShardAction<AnalyzeAction.Request,AnalyzeAction.Response>
-
shards
protected ShardsIterator shards(ClusterState state, TransportSingleShardAction.InternalRequest request)
Description copied from class:TransportSingleShardAction
Returns the candidate shards to execute the operation on ornull
the execute the operation locally (the node that received the request)- Specified by:
shards
in classTransportSingleShardAction<AnalyzeAction.Request,AnalyzeAction.Response>
-
shardOperation
protected AnalyzeAction.Response shardOperation(AnalyzeAction.Request request, ShardId shardId) throws java.io.IOException
- Specified by:
shardOperation
in classTransportSingleShardAction<AnalyzeAction.Request,AnalyzeAction.Response>
- Throws:
java.io.IOException
-
analyze
public static AnalyzeAction.Response analyze(AnalyzeAction.Request request, AnalysisRegistry analysisRegistry, IndexService indexService, int maxTokenCount) throws java.io.IOException
- Throws:
java.io.IOException
-
-