Module org.elasticsearch.server
Class TransportAnalyzeAction
java.lang.Object
org.elasticsearch.action.support.TransportAction<AnalyzeAction.Request,AnalyzeAction.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, projectResolver, threadPool, transportServiceFields inherited from class org.elasticsearch.action.support.TransportAction
actionName, logger, taskManager -
Constructor Summary
ConstructorsConstructorDescriptionTransportAnalyzeAction(Settings settings, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, IndicesService indicesService, ActionFilters actionFilters, ProjectResolver projectResolver, IndexNameExpressionResolver indexNameExpressionResolver) -
Method Summary
Modifier and TypeMethodDescriptionstatic AnalyzeAction.Responseanalyze(AnalyzeAction.Request request, AnalysisRegistry analysisRegistry, IndexService indexService, int maxTokenCount) protected ClusterBlockExceptioncheckRequestBlock(ProjectState state, TransportSingleShardAction<AnalyzeAction.Request, AnalyzeAction.Response>.InternalRequest request) protected Writeable.Reader<AnalyzeAction.Response> protected booleanresolveIndex(AnalyzeAction.Request request) protected AnalyzeAction.ResponseshardOperation(AnalyzeAction.Request request, ShardId shardId) protected ShardsIteratorshards(ProjectState state, TransportSingleShardAction<AnalyzeAction.Request, AnalyzeAction.Response>.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, getProjectState, isSubAction, resolveRequestMethods inherited from class org.elasticsearch.action.support.TransportAction
execute, executeDirect, localOnly
-
Constructor Details
-
TransportAnalyzeAction
@Inject public TransportAnalyzeAction(Settings settings, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, IndicesService indicesService, ActionFilters actionFilters, ProjectResolver projectResolver, IndexNameExpressionResolver indexNameExpressionResolver)
-
-
Method Details
-
getResponseReader
- Specified by:
getResponseReaderin classTransportSingleShardAction<AnalyzeAction.Request,AnalyzeAction.Response>
-
resolveIndex
- Specified by:
resolveIndexin classTransportSingleShardAction<AnalyzeAction.Request,AnalyzeAction.Response>
-
checkRequestBlock
protected ClusterBlockException checkRequestBlock(ProjectState state, TransportSingleShardAction<AnalyzeAction.Request, AnalyzeAction.Response>.InternalRequest request) - Overrides:
checkRequestBlockin classTransportSingleShardAction<AnalyzeAction.Request,AnalyzeAction.Response>
-
shards
protected ShardsIterator shards(ProjectState state, TransportSingleShardAction<AnalyzeAction.Request, AnalyzeAction.Response>.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<AnalyzeAction.Request,AnalyzeAction.Response>
-
shardOperation
protected AnalyzeAction.Response shardOperation(AnalyzeAction.Request request, ShardId shardId) throws IOException - Specified by:
shardOperationin 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
-