Module org.elasticsearch.server

Package org.elasticsearch.action.admin.indices.flush

Class TransportShardFlushAction

java.lang.Object

org.elasticsearch.action.support.TransportAction<ShardFlushRequest,ReplicationResponse>

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

org.elasticsearch.action.admin.indices.flush.TransportShardFlushAction

public class TransportShardFlushAction
extends TransportReplicationAction<ShardFlushRequest,ShardFlushRequest,ReplicationResponse>

Nested Class Summary

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

TransportReplicationAction.ConcreteReplicaRequest<R extends TransportRequest>, TransportReplicationAction.ConcreteShardRequest<R extends TransportRequest>, TransportReplicationAction.PrimaryActionExecution, TransportReplicationAction.PrimaryResult<ReplicaRequest extends ReplicationRequest<ReplicaRequest>,Response extends ReplicationResponse>, TransportReplicationAction.ReplicaActionExecution, TransportReplicationAction.ReplicaResponse, TransportReplicationAction.ReplicaResult, TransportReplicationAction.ReplicasProxy, TransportReplicationAction.RetryOnReplicaException, TransportReplicationAction.SyncGlobalCheckpointAfterOperation

Field Summary

Fields

Modifier and Type	Field	Description
static final String	NAME
static final ActionType<ReplicationResponse>	TYPE

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

clusterService, executor, forceExecutionOnPrimary, indicesService, REPLICATION_INITIAL_RETRY_BACKOFF_BOUND, REPLICATION_RETRY_TIMEOUT, shardStateAction, threadPool, transportOptions, transportPrimaryAction, transportReplicaAction, transportService

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

actionName, logger, taskManager

Constructor Summary

Constructors

Constructor	Description
TransportShardFlushAction(Settings settings, TransportService transportService, ClusterService clusterService, IndicesService indicesService, ThreadPool threadPool, ShardStateAction shardStateAction, ActionFilters actionFilters, ProjectResolver projectResolver)

Method Summary

Modifier and Type	Method	Description
protected Tuple<ReplicationResponse,Exception>	combineSplitResponses(ShardFlushRequest originalRequest, Map<ShardId,ShardFlushRequest> splitRequests, Map<ShardId,Tuple<ReplicationResponse,Exception>> responses)
protected ReplicationResponse	newResponseInstance(StreamInput in)
protected void	shardOperationOnPrimary(ShardFlushRequest shardRequest, IndexShard primary, ActionListener<TransportReplicationAction.PrimaryResult<ShardFlushRequest,ReplicationResponse>> listener)	Primary operation on node with primary copy.
protected void	shardOperationOnReplica(ShardFlushRequest request, IndexShard replica, ActionListener<TransportReplicationAction.ReplicaResult> listener)	Execute the specified replica operation.
protected Map<ShardId,ShardFlushRequest>	splitRequestOnPrimary(ShardFlushRequest request, ProjectMetadata project)	We are here because there was mismatch between the SplitShardCountSummary in the request and that on the primary shard node.

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

acquirePrimaryOperationPermit, acquireReplicaOperationPermit, adaptResponse, checkOperationLimits, checkPrimaryLimits, checkReplicaLimits, doExecute, globalBlockLevel, handlePrimaryRequest, handleReplicaRequest, indexBlockLevel, newReplicasProxy, resolveRequest, retryPrimaryException, transportOptions

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

execute, executeDirect, localOnly

Methods inherited from class java.lang.Object

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

Field Details

NAME

public static final String NAME

See Also:

• Constant Field Values

TYPE

public static final ActionType<ReplicationResponse> TYPE

Constructor Details

TransportShardFlushAction

@Inject
public TransportShardFlushAction(Settings settings,
 TransportService transportService,
 ClusterService clusterService,
 IndicesService indicesService,
 ThreadPool threadPool,
 ShardStateAction shardStateAction,
 ActionFilters actionFilters,
 ProjectResolver projectResolver)

Method Details

newResponseInstance

protected ReplicationResponse newResponseInstance(StreamInput in)
                                           throws IOException

Specified by:

newResponseInstance in class TransportReplicationAction<ShardFlushRequest,ShardFlushRequest,ReplicationResponse>

Throws:

IOException

shardOperationOnPrimary

protected void shardOperationOnPrimary(ShardFlushRequest shardRequest,
 IndexShard primary,
 ActionListener<TransportReplicationAction.PrimaryResult<ShardFlushRequest,ReplicationResponse>> listener)

Description copied from class: TransportReplicationAction

Primary operation on node with primary copy.

Specified by:

shardOperationOnPrimary in class TransportReplicationAction<ShardFlushRequest,ShardFlushRequest,ReplicationResponse>

Parameters:

shardRequest - the request to the primary shard

primary - the primary shard to perform the operation on

splitRequestOnPrimary

protected Map<ShardId,ShardFlushRequest> splitRequestOnPrimary(ShardFlushRequest request,
 ProjectMetadata project)

We are here because there was mismatch between the SplitShardCountSummary in the request and that on the primary shard node. In other words, the primary shard has moved ahead due to a split reshard operation after the request was created by the coordinator. We can assume that the request is exactly 1 reshard split behind the current state of the primary shard. This is because requests that are more than 1 reshard operation behind are rejected in #needsSplitCoordination(org.apache.logging.log4j.Logger, ReplicationRequest, IndexMetadata)

Overrides:

splitRequestOnPrimary in class TransportReplicationAction<ShardFlushRequest,ShardFlushRequest,ReplicationResponse>

combineSplitResponses

protected Tuple<ReplicationResponse,Exception> combineSplitResponses(ShardFlushRequest originalRequest,
 Map<ShardId,ShardFlushRequest> splitRequests,
 Map<ShardId,Tuple<ReplicationResponse,Exception>> responses)

Overrides:

combineSplitResponses in class TransportReplicationAction<ShardFlushRequest,ShardFlushRequest,ReplicationResponse>

shardOperationOnReplica

protected void shardOperationOnReplica(ShardFlushRequest request,
 IndexShard replica,
 ActionListener<TransportReplicationAction.ReplicaResult> listener)

Description copied from class: TransportReplicationAction

Execute the specified replica operation. This is done under a permit from IndexShard.acquireReplicaOperationPermit(long, long, long, ActionListener, Executor).

Specified by:

shardOperationOnReplica in class TransportReplicationAction<ShardFlushRequest,ShardFlushRequest,ReplicationResponse>

Parameters:

request - the request to the replica shard

replica - the replica shard to perform the operation on