org.elasticsearch.action.delete
Class TransportDeleteAction

java.lang.Object
  org.elasticsearch.common.component.AbstractComponent
      org.elasticsearch.action.support.TransportAction<Request,Response>
          org.elasticsearch.action.support.replication.TransportShardReplicationOperationAction<DeleteRequest,DeleteRequest,DeleteResponse>
              org.elasticsearch.action.delete.TransportDeleteAction

public class TransportDeleteAction
extends TransportShardReplicationOperationAction<DeleteRequest,DeleteRequest,DeleteResponse>

Performs the delete operation.

Nested Class Summary

Nested classes/interfaces inherited from class org.elasticsearch.action.support.replication.TransportShardReplicationOperationAction

TransportShardReplicationOperationAction.AsyncShardOperationAction, TransportShardReplicationOperationAction.PrimaryOperationRequest, TransportShardReplicationOperationAction.PrimaryResponse<Response,ReplicaRequest>, TransportShardReplicationOperationAction.ReplicaOperationRequest

Field Summary

Fields inherited from class org.elasticsearch.action.support.replication.TransportShardReplicationOperationAction

clusterService, defaultReplicationType, defaultWriteConsistencyLevel, indicesService, shardStateAction, transportOptions, transportService

Fields inherited from class org.elasticsearch.action.support.TransportAction

threadPool

Fields inherited from class org.elasticsearch.common.component.AbstractComponent

componentSettings, logger, settings

Constructor Summary

TransportDeleteAction(Settings settings, TransportService transportService, ClusterService clusterService, IndicesService indicesService, ThreadPool threadPool, ShardStateAction shardStateAction, TransportCreateIndexAction createIndexAction, TransportIndexDeleteAction indexDeleteAction)

Method Summary

protected ClusterBlockException	checkGlobalBlock(ClusterState state, DeleteRequest request)
protected ClusterBlockException	checkRequestBlock(ClusterState state, DeleteRequest request)
protected boolean	checkWriteConsistency()
protected void	doExecute(DeleteRequest request, ActionListener<DeleteResponse> listener)
protected String	executor()
protected DeleteRequest	newReplicaRequestInstance()
protected DeleteRequest	newRequestInstance()
protected DeleteResponse	newResponseInstance()
protected boolean	resolveRequest(ClusterState state, DeleteRequest request, ActionListener<DeleteResponse> listener) Resolves the request, by default, simply setting the concrete index (if its aliased one).
protected TransportShardReplicationOperationAction.PrimaryResponse<DeleteResponse,DeleteRequest>	shardOperationOnPrimary(ClusterState clusterState, TransportShardReplicationOperationAction.PrimaryOperationRequest shardRequest)
protected void	shardOperationOnReplica(TransportShardReplicationOperationAction.ReplicaOperationRequest shardRequest)
protected ShardIterator	shards(ClusterState clusterState, DeleteRequest request)
protected String	transportAction()

Methods inherited from class org.elasticsearch.action.support.replication.TransportShardReplicationOperationAction

ignoreReplicas, postPrimaryOperation, retryPrimaryException, transportOptions

Methods inherited from class org.elasticsearch.action.support.TransportAction

execute, execute

Methods inherited from class org.elasticsearch.common.component.AbstractComponent

nodeName

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TransportDeleteAction

@Inject
public TransportDeleteAction(Settings settings,
                                    TransportService transportService,
                                    ClusterService clusterService,
                                    IndicesService indicesService,
                                    ThreadPool threadPool,
                                    ShardStateAction shardStateAction,
                                    TransportCreateIndexAction createIndexAction,
                                    TransportIndexDeleteAction indexDeleteAction)

Method Detail

executor

protected String executor()

Specified by:

executor in class TransportShardReplicationOperationAction<DeleteRequest,DeleteRequest,DeleteResponse>

doExecute

protected void doExecute(DeleteRequest request,
                         ActionListener<DeleteResponse> listener)

Overrides:

doExecute in class TransportShardReplicationOperationAction<DeleteRequest,DeleteRequest,DeleteResponse>

resolveRequest

protected boolean resolveRequest(ClusterState state,
                                 DeleteRequest request,
                                 ActionListener<DeleteResponse> listener)

Description copied from class: TransportShardReplicationOperationAction

Resolves the request, by default, simply setting the concrete index (if its aliased one). If the resolve means a different execution, then return false here to indicate not to continue and execute this request.

Overrides:

resolveRequest in class TransportShardReplicationOperationAction<DeleteRequest,DeleteRequest,DeleteResponse>

checkWriteConsistency

protected boolean checkWriteConsistency()

Specified by:

checkWriteConsistency in class TransportShardReplicationOperationAction<DeleteRequest,DeleteRequest,DeleteResponse>

newRequestInstance

protected DeleteRequest newRequestInstance()

Specified by:

newRequestInstance in class TransportShardReplicationOperationAction<DeleteRequest,DeleteRequest,DeleteResponse>

newReplicaRequestInstance

protected DeleteRequest newReplicaRequestInstance()

Specified by:

newReplicaRequestInstance in class TransportShardReplicationOperationAction<DeleteRequest,DeleteRequest,DeleteResponse>

newResponseInstance

protected DeleteResponse newResponseInstance()

Specified by:

newResponseInstance in class TransportShardReplicationOperationAction<DeleteRequest,DeleteRequest,DeleteResponse>

transportAction

protected String transportAction()

Specified by:

transportAction in class TransportShardReplicationOperationAction<DeleteRequest,DeleteRequest,DeleteResponse>

checkGlobalBlock

protected ClusterBlockException checkGlobalBlock(ClusterState state,
                                                 DeleteRequest request)

Specified by:

checkGlobalBlock in class TransportShardReplicationOperationAction<DeleteRequest,DeleteRequest,DeleteResponse>

checkRequestBlock

protected ClusterBlockException checkRequestBlock(ClusterState state,
                                                  DeleteRequest request)

Specified by:

checkRequestBlock in class TransportShardReplicationOperationAction<DeleteRequest,DeleteRequest,DeleteResponse>

shardOperationOnPrimary

protected TransportShardReplicationOperationAction.PrimaryResponse<DeleteResponse,DeleteRequest> shardOperationOnPrimary(ClusterState clusterState,
                                                                                                                         TransportShardReplicationOperationAction.PrimaryOperationRequest shardRequest)

Specified by:

shardOperationOnPrimary in class TransportShardReplicationOperationAction<DeleteRequest,DeleteRequest,DeleteResponse>

shardOperationOnReplica

protected void shardOperationOnReplica(TransportShardReplicationOperationAction.ReplicaOperationRequest shardRequest)

Specified by:

shardOperationOnReplica in class TransportShardReplicationOperationAction<DeleteRequest,DeleteRequest,DeleteResponse>

shards

protected ShardIterator shards(ClusterState clusterState,
                               DeleteRequest request)

Specified by:

shards in class TransportShardReplicationOperationAction<DeleteRequest,DeleteRequest,DeleteResponse>