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, localConnection, logger, taskManager
-
Constructor Summary
ConstructorDescriptionTransportAnalyzeAction(Settings settings, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, IndicesService indicesService, ActionFilters actionFilters, IndexNameExpressionResolver indexNameExpressionResolver)
-
Method Summary
Modifier and TypeMethodDescriptionstatic 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>
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 Details
-
TransportAnalyzeAction
@Inject public TransportAnalyzeAction(Settings settings, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, IndicesService indicesService, ActionFilters actionFilters, IndexNameExpressionResolver indexNameExpressionResolver)
-
-
Method Details
-
getResponseReader
- Specified by:
getResponseReader
in classTransportSingleShardAction<AnalyzeAction.Request,AnalyzeAction.Response>
-
resolveIndex
- 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 IOException- Specified by:
shardOperation
in classTransportSingleShardAction<AnalyzeAction.Request,AnalyzeAction.Response>
- Throws:
IOException
-
analyze
public static AnalyzeAction.Response analyze(AnalyzeAction.Request request, AnalysisRegistry analysisRegistry, IndexService indexService, int maxTokenCount) throws IOException- Throws:
IOException
-