org.elasticsearch.action.admin.indices.refresh

Class TransportShardRefreshAction

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

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

org.elasticsearch.action.support.replication.TransportReplicationAction<BasicReplicationRequest,BasicReplicationRequest,ReplicationResponse>

org.elasticsearch.action.admin.indices.refresh.TransportShardRefreshAction

public class TransportShardRefreshAction
extends TransportReplicationAction<BasicReplicationRequest,BasicReplicationRequest,ReplicationResponse>

Nested Class Summary

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

TransportReplicationAction.ConcreteShardRequest<R extends ReplicationRequest<?>>, TransportReplicationAction.PrimaryResult<ReplicaRequest extends ReplicationRequest<ReplicaRequest>,Response extends ReplicationResponse>, TransportReplicationAction.ReplicaResult, TransportReplicationAction.RetryOnReplicaException

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	NAME

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

clusterService

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

actionName, indexNameExpressionResolver, taskManager, threadPool

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

deprecationLogger, logger, settings

Constructor Summary

Constructors

Constructor and Description
TransportShardRefreshAction(Settings settings, TransportService transportService, ClusterService clusterService, IndicesService indicesService, ThreadPool threadPool, ShardStateAction shardStateAction, ActionFilters actionFilters, IndexNameExpressionResolver indexNameExpressionResolver)

Method Summary

Modifier and Type	Method and Description
protected ReplicationResponse	newResponseInstance()
protected TransportReplicationAction.PrimaryResult	shardOperationOnPrimary(BasicReplicationRequest shardRequest, IndexShard primary) Primary operation on node with primary copy.
protected TransportReplicationAction.ReplicaResult	shardOperationOnReplica(BasicReplicationRequest request, IndexShard replica) Synchronous replica operation on nodes with replica copies.
protected boolean	shouldExecuteReplication(IndexMetaData indexMetaData) Indicated whether this operation should be replicated to shadow replicas or not.

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

doExecute, doExecute, globalBlockLevel, indexBlockLevel, resolveIndex, resolveRequest, retryPrimaryException, transportOptions

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

execute, execute, execute, execute

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

logDeprecatedSetting, logRemovedSetting, nodeName

Methods inherited from class java.lang.Object

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

Field Detail

NAME

public static final java.lang.String NAME

See Also:

Constant Field Values

Constructor Detail

TransportShardRefreshAction

@Inject
public TransportShardRefreshAction(Settings settings,
                                           TransportService transportService,
                                           ClusterService clusterService,
                                           IndicesService indicesService,
                                           ThreadPool threadPool,
                                           ShardStateAction shardStateAction,
                                           ActionFilters actionFilters,
                                           IndexNameExpressionResolver indexNameExpressionResolver)

Method Detail

newResponseInstance

protected ReplicationResponse newResponseInstance()

Specified by:

newResponseInstance in class TransportReplicationAction<BasicReplicationRequest,BasicReplicationRequest,ReplicationResponse>

shardOperationOnPrimary

protected TransportReplicationAction.PrimaryResult shardOperationOnPrimary(BasicReplicationRequest shardRequest,
                                                                           IndexShard primary)

Description copied from class: TransportReplicationAction

Primary operation on node with primary copy.

Specified by:

shardOperationOnPrimary in class TransportReplicationAction<BasicReplicationRequest,BasicReplicationRequest,ReplicationResponse>

Parameters:

shardRequest - the request to the primary shard

primary - the primary shard to perform the operation on

shardOperationOnReplica

protected TransportReplicationAction.ReplicaResult shardOperationOnReplica(BasicReplicationRequest request,
                                                                           IndexShard replica)

Description copied from class: TransportReplicationAction

Synchronous replica operation on nodes with replica copies. This is done under the lock form IndexShard.acquireReplicaOperationLock(long, ActionListener, String)

Specified by:

shardOperationOnReplica in class TransportReplicationAction<BasicReplicationRequest,BasicReplicationRequest,ReplicationResponse>

Parameters:

request - the request to the replica shard

replica - the replica shard to perform the operation on

shouldExecuteReplication

protected boolean shouldExecuteReplication(IndexMetaData indexMetaData)

Description copied from class: TransportReplicationAction

Indicated whether this operation should be replicated to shadow replicas or not. If this method returns true the replication phase will be skipped. For example writes such as index and delete don't need to be replicated on shadow replicas but refresh and flush do.

Overrides:

shouldExecuteReplication in class TransportReplicationAction<BasicReplicationRequest,BasicReplicationRequest,ReplicationResponse>