public class TransportShardDeleteByQueryAction extends TransportShardReplicationOperationAction<ShardDeleteByQueryRequest,ShardDeleteByQueryRequest,ShardDeleteByQueryResponse>
TransportShardReplicationOperationAction.AsyncShardOperationAction, TransportShardReplicationOperationAction.InternalRequest, TransportShardReplicationOperationAction.PrimaryOperationRequest, TransportShardReplicationOperationAction.PrimaryResponse<Response,ReplicaRequest>, TransportShardReplicationOperationAction.ReplicaOperationRequest
Modifier and Type | Field and Description |
---|---|
static String |
DELETE_BY_QUERY_API |
clusterService, defaultReplicationType, defaultWriteConsistencyLevel, indicesService, shardStateAction, transportOptions, transportService
actionName, threadPool
componentSettings, logger, settings
Constructor and Description |
---|
TransportShardDeleteByQueryAction(Settings settings,
TransportService transportService,
ClusterService clusterService,
IndicesService indicesService,
ThreadPool threadPool,
ShardStateAction shardStateAction,
ScriptService scriptService,
CacheRecycler cacheRecycler,
PageCacheRecycler pageCacheRecycler,
BigArrays bigArrays,
ActionFilters actionFilters) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
checkWriteConsistency() |
protected String |
executor() |
protected ShardDeleteByQueryRequest |
newReplicaRequestInstance() |
protected ShardDeleteByQueryRequest |
newRequestInstance() |
protected ShardDeleteByQueryResponse |
newResponseInstance() |
protected boolean |
resolveIndex() |
protected TransportShardReplicationOperationAction.PrimaryResponse<ShardDeleteByQueryResponse,ShardDeleteByQueryRequest> |
shardOperationOnPrimary(ClusterState clusterState,
TransportShardReplicationOperationAction.PrimaryOperationRequest shardRequest) |
protected void |
shardOperationOnReplica(TransportShardReplicationOperationAction.ReplicaOperationRequest shardRequest) |
protected ShardIterator |
shards(ClusterState clusterState,
TransportShardReplicationOperationAction.InternalRequest request) |
checkGlobalBlock, checkRequestBlock, doExecute, ignoreReplicaException, ignoreReplicas, isConflictException, postPrimaryOperation, resolveRequest, retryPrimaryException, transportOptions
execute, execute, forceThreadedListener
nodeName
public static final String DELETE_BY_QUERY_API
@Inject public TransportShardDeleteByQueryAction(Settings settings, TransportService transportService, ClusterService clusterService, IndicesService indicesService, ThreadPool threadPool, ShardStateAction shardStateAction, ScriptService scriptService, CacheRecycler cacheRecycler, PageCacheRecycler pageCacheRecycler, BigArrays bigArrays, ActionFilters actionFilters)
protected boolean checkWriteConsistency()
protected String executor()
protected ShardDeleteByQueryRequest newRequestInstance()
protected ShardDeleteByQueryRequest newReplicaRequestInstance()
protected ShardDeleteByQueryResponse newResponseInstance()
protected boolean resolveIndex()
protected TransportShardReplicationOperationAction.PrimaryResponse<ShardDeleteByQueryResponse,ShardDeleteByQueryRequest> shardOperationOnPrimary(ClusterState clusterState, TransportShardReplicationOperationAction.PrimaryOperationRequest shardRequest)
protected void shardOperationOnReplica(TransportShardReplicationOperationAction.ReplicaOperationRequest shardRequest)
protected ShardIterator shards(ClusterState clusterState, TransportShardReplicationOperationAction.InternalRequest request)
Copyright © 2009–2015. All rights reserved.