public abstract class TransportIndicesReplicationOperationAction<Request extends IndicesReplicationOperationRequest,Response extends ActionResponse,IndexRequest extends IndexReplicationOperationRequest,IndexResponse extends ActionResponse,ShardRequest extends ShardReplicationOperationRequest,ShardReplicaRequest extends ShardReplicationOperationRequest,ShardResponse extends ActionResponse> extends TransportAction<Request,Response>
Modifier and Type | Field and Description |
---|---|
protected ClusterService |
clusterService |
protected TransportIndexReplicationOperationAction<IndexRequest,IndexResponse,ShardRequest,ShardReplicaRequest,ShardResponse> |
indexAction |
actionName, threadPool
componentSettings, logger, settings
Modifier | Constructor and Description |
---|---|
protected |
TransportIndicesReplicationOperationAction(Settings settings,
String actionName,
TransportService transportService,
ClusterService clusterService,
ThreadPool threadPool,
TransportIndexReplicationOperationAction<IndexRequest,IndexResponse,ShardRequest,ShardReplicaRequest,ShardResponse> indexAction,
ActionFilters actionFilters) |
Modifier and Type | Method and Description |
---|---|
protected abstract boolean |
accumulateExceptions() |
protected abstract ClusterBlockException |
checkGlobalBlock(ClusterState state,
Request request) |
protected abstract ClusterBlockException |
checkRequestBlock(ClusterState state,
Request request,
String[] concreteIndices) |
protected void |
doExecute(Request request,
ActionListener<Response> listener) |
protected abstract IndexRequest |
newIndexRequestInstance(Request request,
String index,
Set<String> routing,
long startTimeInMillis) |
protected abstract Request |
newRequestInstance() |
protected abstract Response |
newResponseInstance(Request request,
AtomicReferenceArray indexResponses) |
protected abstract Map<String,Set<String>> |
resolveRouting(ClusterState clusterState,
Request request) |
execute, execute, forceThreadedListener
nodeName
protected final ClusterService clusterService
protected final TransportIndexReplicationOperationAction<IndexRequest extends IndexReplicationOperationRequest,IndexResponse extends ActionResponse,ShardRequest extends ShardReplicationOperationRequest,ShardReplicaRequest extends ShardReplicationOperationRequest,ShardResponse extends ActionResponse> indexAction
protected TransportIndicesReplicationOperationAction(Settings settings, String actionName, TransportService transportService, ClusterService clusterService, ThreadPool threadPool, TransportIndexReplicationOperationAction<IndexRequest,IndexResponse,ShardRequest,ShardReplicaRequest,ShardResponse> indexAction, ActionFilters actionFilters)
protected abstract Map<String,Set<String>> resolveRouting(ClusterState clusterState, Request request) throws ElasticsearchException
ElasticsearchException
protected void doExecute(Request request, ActionListener<Response> listener)
doExecute
in class TransportAction<Request extends IndicesReplicationOperationRequest,Response extends ActionResponse>
protected abstract Request newRequestInstance()
protected abstract Response newResponseInstance(Request request, AtomicReferenceArray indexResponses)
protected abstract IndexRequest newIndexRequestInstance(Request request, String index, Set<String> routing, long startTimeInMillis)
protected abstract boolean accumulateExceptions()
protected abstract ClusterBlockException checkGlobalBlock(ClusterState state, Request request)
protected abstract ClusterBlockException checkRequestBlock(ClusterState state, Request request, String[] concreteIndices)
Copyright © 2009–2015. All rights reserved.