org.elasticsearch.action.delete

Class TransportIndexDeleteAction

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

org.elasticsearch.action.support.TransportAction<Request,Response>

org.elasticsearch.action.support.replication.TransportIndexReplicationOperationAction<org.elasticsearch.action.delete.IndexDeleteRequest,IndexDeleteResponse,ShardDeleteRequest,ShardDeleteRequest,ShardDeleteResponse>

org.elasticsearch.action.delete.TransportIndexDeleteAction

public class TransportIndexDeleteAction
extends TransportIndexReplicationOperationAction<org.elasticsearch.action.delete.IndexDeleteRequest,IndexDeleteResponse,ShardDeleteRequest,ShardDeleteRequest,ShardDeleteResponse>

Internal transport action that broadcasts a delete request to all of the shards that belongs to an index. Used when routing is required but not specified within the delete request.

Field Summary

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

clusterService, shardAction

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

actionName, threadPool

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

componentSettings, logger, settings

Constructor Summary

Constructors

Constructor and Description
TransportIndexDeleteAction(Settings settings, ClusterService clusterService, ThreadPool threadPool, TransportShardDeleteAction deleteAction, ActionFilters actionFilters)

Method Summary

Modifier and Type	Method and Description
protected boolean	accumulateExceptions()
protected IndexDeleteResponse	newResponseInstance(org.elasticsearch.action.delete.IndexDeleteRequest request, List<ShardDeleteResponse> shardDeleteResponses, int failuresCount, List<ShardOperationFailedException> shardFailures)
protected ShardDeleteRequest	newShardRequestInstance(org.elasticsearch.action.delete.IndexDeleteRequest request, int shardId)
protected GroupShardsIterator	shards(org.elasticsearch.action.delete.IndexDeleteRequest request)

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

checkGlobalBlock, checkRequestBlock, doExecute

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

execute, execute, forceThreadedListener

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

TransportIndexDeleteAction

@Inject
public TransportIndexDeleteAction(Settings settings,
                                          ClusterService clusterService,
                                          ThreadPool threadPool,
                                          TransportShardDeleteAction deleteAction,
                                          ActionFilters actionFilters)

Method Detail

newResponseInstance

protected IndexDeleteResponse newResponseInstance(org.elasticsearch.action.delete.IndexDeleteRequest request,
                                                  List<ShardDeleteResponse> shardDeleteResponses,
                                                  int failuresCount,
                                                  List<ShardOperationFailedException> shardFailures)

Specified by:

newResponseInstance in class TransportIndexReplicationOperationAction<org.elasticsearch.action.delete.IndexDeleteRequest,IndexDeleteResponse,ShardDeleteRequest,ShardDeleteRequest,ShardDeleteResponse>

accumulateExceptions

protected boolean accumulateExceptions()

Specified by:

accumulateExceptions in class TransportIndexReplicationOperationAction<org.elasticsearch.action.delete.IndexDeleteRequest,IndexDeleteResponse,ShardDeleteRequest,ShardDeleteRequest,ShardDeleteResponse>

shards

protected GroupShardsIterator shards(org.elasticsearch.action.delete.IndexDeleteRequest request)

Specified by:

shards in class TransportIndexReplicationOperationAction<org.elasticsearch.action.delete.IndexDeleteRequest,IndexDeleteResponse,ShardDeleteRequest,ShardDeleteRequest,ShardDeleteResponse>

newShardRequestInstance

protected ShardDeleteRequest newShardRequestInstance(org.elasticsearch.action.delete.IndexDeleteRequest request,
                                                     int shardId)

Specified by:

newShardRequestInstance in class TransportIndexReplicationOperationAction<org.elasticsearch.action.delete.IndexDeleteRequest,IndexDeleteResponse,ShardDeleteRequest,ShardDeleteRequest,ShardDeleteResponse>