org.elasticsearch.action.bulk

Class TransportShardBulkAction

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

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

org.elasticsearch.action.support.replication.TransportShardReplicationOperationAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>

org.elasticsearch.action.bulk.TransportShardBulkAction

public class TransportShardBulkAction
extends TransportShardReplicationOperationAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>

Performs the index operation.

Nested Class Summary

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

TransportShardReplicationOperationAction.InternalRequest, TransportShardReplicationOperationAction.PrimaryOperationRequest, TransportShardReplicationOperationAction.ReplicaOperationRequest

Field Summary

Fields

Modifier and Type	Field and Description
static String	ACTION_NAME

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

actionName, threadPool

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

componentSettings, logger, settings

Constructor Summary

Constructors

Constructor and Description
TransportShardBulkAction(Settings settings, TransportService transportService, ClusterService clusterService, IndicesService indicesService, ThreadPool threadPool, ShardStateAction shardStateAction, MappingUpdatedAction mappingUpdatedAction, UpdateHelper updateHelper, ActionFilters actionFilters)

Method Summary

Modifier and Type	Method and Description
protected boolean	checkWriteConsistency()
protected String	executor()
protected BulkShardRequest	newReplicaRequestInstance()
protected BulkShardRequest	newRequestInstance()
protected BulkShardResponse	newResponseInstance()
protected boolean	resolveIndex()
protected Tuple<BulkShardResponse,BulkShardRequest>	shardOperationOnPrimary(ClusterState clusterState, TransportShardReplicationOperationAction.PrimaryOperationRequest shardRequest)
protected void	shardOperationOnReplica(TransportShardReplicationOperationAction.ReplicaOperationRequest shardRequest)
protected ShardIterator	shards(ClusterState clusterState, TransportShardReplicationOperationAction.InternalRequest request)
protected TransportRequestOptions	transportOptions()

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

checkGlobalBlock, checkRequestBlock, doExecute, getIndexShardOperationsCounter, ignoreReplicaException, isConflictException, resolveRequest, retryPrimaryException

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

Field Detail

ACTION_NAME

public static final String ACTION_NAME

See Also:

Constant Field Values

Constructor Detail

TransportShardBulkAction

@Inject
public TransportShardBulkAction(Settings settings,
                                        TransportService transportService,
                                        ClusterService clusterService,
                                        IndicesService indicesService,
                                        ThreadPool threadPool,
                                        ShardStateAction shardStateAction,
                                        MappingUpdatedAction mappingUpdatedAction,
                                        UpdateHelper updateHelper,
                                        ActionFilters actionFilters)

Method Detail

executor

protected String executor()

Specified by:

executor in class TransportShardReplicationOperationAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>

checkWriteConsistency

protected boolean checkWriteConsistency()

Specified by:

checkWriteConsistency in class TransportShardReplicationOperationAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>

transportOptions

protected TransportRequestOptions transportOptions()

Overrides:

transportOptions in class TransportShardReplicationOperationAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>

newRequestInstance

protected BulkShardRequest newRequestInstance()

Specified by:

newRequestInstance in class TransportShardReplicationOperationAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>

newReplicaRequestInstance

protected BulkShardRequest newReplicaRequestInstance()

Specified by:

newReplicaRequestInstance in class TransportShardReplicationOperationAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>

newResponseInstance

protected BulkShardResponse newResponseInstance()

Specified by:

newResponseInstance in class TransportShardReplicationOperationAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>

resolveIndex

protected boolean resolveIndex()

Specified by:

resolveIndex in class TransportShardReplicationOperationAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>

shards

protected ShardIterator shards(ClusterState clusterState,
                               TransportShardReplicationOperationAction.InternalRequest request)

Specified by:

shards in class TransportShardReplicationOperationAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>

shardOperationOnPrimary

protected Tuple<BulkShardResponse,BulkShardRequest> shardOperationOnPrimary(ClusterState clusterState,
                                                                            TransportShardReplicationOperationAction.PrimaryOperationRequest shardRequest)

Specified by:

shardOperationOnPrimary in class TransportShardReplicationOperationAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>

Returns:

A tuple containing not null values, as first value the result of the primary operation and as second value the request to be executed on the replica shards.

shardOperationOnReplica

protected void shardOperationOnReplica(TransportShardReplicationOperationAction.ReplicaOperationRequest shardRequest)

Specified by:

shardOperationOnReplica in class TransportShardReplicationOperationAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>