org.elasticsearch.action.index

Class TransportIndexAction

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

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

org.elasticsearch.action.support.replication.TransportShardReplicationOperationAction<IndexRequest,IndexRequest,IndexResponse>

org.elasticsearch.action.index.TransportIndexAction

public class TransportIndexAction
extends TransportShardReplicationOperationAction<IndexRequest,IndexRequest,IndexResponse>

Performs the index operation.

Allows for the following settings:

• autoCreateIndex: When set to true, will automatically create an index if one does not exists. Defaults to true.
• allowIdGeneration: If the id is set not, should it be generated. Defaults to true.

Nested Class Summary

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

TransportShardReplicationOperationAction.InternalRequest, TransportShardReplicationOperationAction.PrimaryOperationRequest, 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

actionName, threadPool

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

componentSettings, logger, settings

Constructor Summary

Constructors

Constructor and Description
TransportIndexAction(Settings settings, TransportService transportService, ClusterService clusterService, IndicesService indicesService, ThreadPool threadPool, ShardStateAction shardStateAction, TransportCreateIndexAction createIndexAction, MappingUpdatedAction mappingUpdatedAction, ActionFilters actionFilters)

Method Summary

Modifier and Type	Method and Description
protected boolean	checkWriteConsistency()
protected void	doExecute(IndexRequest request, ActionListener<IndexResponse> listener)
protected String	executor()
protected IndexRequest	newReplicaRequestInstance()
protected IndexRequest	newRequestInstance()
protected IndexResponse	newResponseInstance()
protected boolean	resolveIndex()
protected boolean	resolveRequest(ClusterState state, TransportShardReplicationOperationAction.InternalRequest request, ActionListener<IndexResponse> indexResponseActionListener) Resolves the request, by default doing nothing.
protected Tuple<IndexResponse,IndexRequest>	shardOperationOnPrimary(ClusterState clusterState, TransportShardReplicationOperationAction.PrimaryOperationRequest shardRequest)
protected void	shardOperationOnReplica(TransportShardReplicationOperationAction.ReplicaOperationRequest shardRequest)
protected ShardIterator	shards(ClusterState clusterState, TransportShardReplicationOperationAction.InternalRequest request)

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

checkGlobalBlock, checkRequestBlock, getIndexShardOperationsCounter, ignoreReplicaException, isConflictException, retryPrimaryException, transportOptions

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

TransportIndexAction

@Inject
public TransportIndexAction(Settings settings,
                                    TransportService transportService,
                                    ClusterService clusterService,
                                    IndicesService indicesService,
                                    ThreadPool threadPool,
                                    ShardStateAction shardStateAction,
                                    TransportCreateIndexAction createIndexAction,
                                    MappingUpdatedAction mappingUpdatedAction,
                                    ActionFilters actionFilters)

Method Detail

doExecute

protected void doExecute(IndexRequest request,
                         ActionListener<IndexResponse> listener)

Overrides:

doExecute in class TransportShardReplicationOperationAction<IndexRequest,IndexRequest,IndexResponse>

resolveIndex

protected boolean resolveIndex()

Specified by:

resolveIndex in class TransportShardReplicationOperationAction<IndexRequest,IndexRequest,IndexResponse>

resolveRequest

protected boolean resolveRequest(ClusterState state,
                                 TransportShardReplicationOperationAction.InternalRequest request,
                                 ActionListener<IndexResponse> indexResponseActionListener)

Description copied from class: TransportShardReplicationOperationAction

Resolves the request, by default doing nothing. 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<IndexRequest,IndexRequest,IndexResponse>

checkWriteConsistency

protected boolean checkWriteConsistency()

Specified by:

checkWriteConsistency in class TransportShardReplicationOperationAction<IndexRequest,IndexRequest,IndexResponse>

newRequestInstance

protected IndexRequest newRequestInstance()

Specified by:

newRequestInstance in class TransportShardReplicationOperationAction<IndexRequest,IndexRequest,IndexResponse>

newReplicaRequestInstance

protected IndexRequest newReplicaRequestInstance()

Specified by:

newReplicaRequestInstance in class TransportShardReplicationOperationAction<IndexRequest,IndexRequest,IndexResponse>

newResponseInstance

protected IndexResponse newResponseInstance()

Specified by:

newResponseInstance in class TransportShardReplicationOperationAction<IndexRequest,IndexRequest,IndexResponse>

executor

protected String executor()

Specified by:

executor in class TransportShardReplicationOperationAction<IndexRequest,IndexRequest,IndexResponse>

shards

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

Specified by:

shards in class TransportShardReplicationOperationAction<IndexRequest,IndexRequest,IndexResponse>

shardOperationOnPrimary

protected Tuple<IndexResponse,IndexRequest> shardOperationOnPrimary(ClusterState clusterState,
                                                                    TransportShardReplicationOperationAction.PrimaryOperationRequest shardRequest)
                                                             throws Throwable

Specified by:

shardOperationOnPrimary in class TransportShardReplicationOperationAction<IndexRequest,IndexRequest,IndexResponse>

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.

Throws:

Throwable

shardOperationOnReplica

protected void shardOperationOnReplica(TransportShardReplicationOperationAction.ReplicaOperationRequest shardRequest)

Specified by:

shardOperationOnReplica in class TransportShardReplicationOperationAction<IndexRequest,IndexRequest,IndexResponse>