Package org.elasticsearch.action.bulk
Class TransportShardBulkAction
java.lang.Object
org.elasticsearch.action.support.TransportAction<Request,Response>
org.elasticsearch.action.support.replication.TransportReplicationAction<Request,ReplicaRequest,Response>
org.elasticsearch.action.support.replication.TransportWriteAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>
org.elasticsearch.action.bulk.TransportShardBulkAction
public class TransportShardBulkAction extends TransportWriteAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>
Performs shard-level bulk (index, delete or update) operations
-
Nested Class Summary
Nested classes/interfaces inherited from class org.elasticsearch.action.support.replication.TransportWriteAction
TransportWriteAction.WritePrimaryResult<ReplicaRequest extends ReplicatedWriteRequest<ReplicaRequest>,Response extends ReplicationResponse & WriteResponse>, TransportWriteAction.WriteReplicaResult<ReplicaRequest extends ReplicatedWriteRequest<ReplicaRequest>>
Nested classes/interfaces inherited from class org.elasticsearch.action.support.replication.TransportReplicationAction
TransportReplicationAction.ConcreteReplicaRequest<R extends TransportRequest>, TransportReplicationAction.ConcreteShardRequest<R extends TransportRequest>, TransportReplicationAction.PrimaryResult<ReplicaRequest extends ReplicationRequest<ReplicaRequest>,Response extends ReplicationResponse>, TransportReplicationAction.ReplicaResponse, TransportReplicationAction.ReplicaResult, TransportReplicationAction.ReplicasProxy, TransportReplicationAction.RetryOnReplicaException
-
Field Summary
Fields Modifier and Type Field Description static java.lang.String
ACTION_NAME
Fields inherited from class org.elasticsearch.action.support.replication.TransportWriteAction
indexingPressure, systemIndices
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, taskManager
-
Constructor Summary
Constructors Constructor Description TransportShardBulkAction(Settings settings, TransportService transportService, ClusterService clusterService, IndicesService indicesService, ThreadPool threadPool, ShardStateAction shardStateAction, MappingUpdatedAction mappingUpdatedAction, UpdateHelper updateHelper, ActionFilters actionFilters, IndexingPressure indexingPressure, SystemIndices systemIndices)
-
Method Summary
Methods inherited from class org.elasticsearch.action.support.replication.TransportWriteAction
checkOperationLimits, checkPrimaryLimits, checkReplicaLimits, executor, force, globalBlockLevel, indexBlockLevel, isSystemShard, locationToSync, newReplicasProxy, shardOperationOnPrimary, shardOperationOnReplica, syncOperationResultOrThrow
Methods inherited from class org.elasticsearch.action.support.replication.TransportReplicationAction
acquirePrimaryOperationPermit, acquireReplicaOperationPermit, adaptResponse, doExecute, handlePrimaryRequest, handleReplicaRequest, resolveRequest, retryPrimaryException
Methods inherited from class org.elasticsearch.action.support.TransportAction
execute, execute, execute
-
Field Details
-
ACTION_NAME
public static final java.lang.String ACTION_NAME- See Also:
- Constant Field Values
-
-
Constructor Details
-
TransportShardBulkAction
@Inject public TransportShardBulkAction(Settings settings, TransportService transportService, ClusterService clusterService, IndicesService indicesService, ThreadPool threadPool, ShardStateAction shardStateAction, MappingUpdatedAction mappingUpdatedAction, UpdateHelper updateHelper, ActionFilters actionFilters, IndexingPressure indexingPressure, SystemIndices systemIndices)
-
-
Method Details
-
transportOptions
- Overrides:
transportOptions
in classTransportReplicationAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>
-
newResponseInstance
- Specified by:
newResponseInstance
in classTransportReplicationAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>
- Throws:
java.io.IOException
-
dispatchedShardOperationOnPrimary
protected void dispatchedShardOperationOnPrimary(BulkShardRequest request, IndexShard primary, ActionListener<TransportReplicationAction.PrimaryResult<BulkShardRequest,BulkShardResponse>> listener)- Specified by:
dispatchedShardOperationOnPrimary
in classTransportWriteAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>
-
primaryOperationSize
- Overrides:
primaryOperationSize
in classTransportWriteAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>
-
performOnPrimary
public static void performOnPrimary(BulkShardRequest request, IndexShard primary, UpdateHelper updateHelper, java.util.function.LongSupplier nowInMillisSupplier, MappingUpdatePerformer mappingUpdater, java.util.function.Consumer<ActionListener<java.lang.Void>> waitForMappingUpdate, ActionListener<TransportReplicationAction.PrimaryResult<BulkShardRequest,BulkShardResponse>> listener, ThreadPool threadPool, java.lang.String executorName) -
dispatchedShardOperationOnReplica
protected void dispatchedShardOperationOnReplica(BulkShardRequest request, IndexShard replica, ActionListener<TransportReplicationAction.ReplicaResult> listener)- Specified by:
dispatchedShardOperationOnReplica
in classTransportWriteAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>
-
replicaOperationSize
- Overrides:
replicaOperationSize
in classTransportWriteAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>
-
performOnReplica
public static Translog.Location performOnReplica(BulkShardRequest request, IndexShard replica) throws java.lang.Exception- Throws:
java.lang.Exception
-