public class TransportShardBulkAction extends TransportWriteAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>
Modifier and Type | Class | Description |
---|---|---|
static class |
TransportShardBulkAction.ReplicaItemExecutionMode |
Modes for executing item request on replica depending on corresponding primary execution result
|
TransportReplicationAction.ConcreteReplicaRequest<R extends TransportRequest>, TransportReplicationAction.ConcreteShardRequest<R extends TransportRequest>, TransportReplicationAction.OperationTransportHandler, TransportReplicationAction.PrimaryOperationTransportHandler, TransportReplicationAction.PrimaryResult<ReplicaRequest extends ReplicationRequest<ReplicaRequest>,Response extends ReplicationResponse>, TransportReplicationAction.ReplicaOperationTransportHandler, TransportReplicationAction.ReplicaResponse, TransportReplicationAction.ReplicaResult, TransportReplicationAction.ReplicasProxy, TransportReplicationAction.RetryOnReplicaException
TransportWriteAction.WritePrimaryResult<ReplicaRequest extends ReplicatedWriteRequest<ReplicaRequest>,Response extends ReplicationResponse & WriteResponse>, TransportWriteAction.WriteReplicaResult<ReplicaRequest extends ReplicatedWriteRequest<ReplicaRequest>>
Modifier and Type | Field | Description |
---|---|---|
static java.lang.String |
ACTION_NAME |
deprecationLogger, settings
actionName, indexNameExpressionResolver, taskManager, threadPool
clusterService, executor, indicesService, shardStateAction, transportOptions, transportPrimaryAction, transportReplicaAction, transportService
Constructor | Description |
---|---|
TransportShardBulkAction(Settings settings,
TransportService transportService,
ClusterService clusterService,
IndicesService indicesService,
ThreadPool threadPool,
ShardStateAction shardStateAction,
MappingUpdatedAction mappingUpdatedAction,
UpdateHelper updateHelper,
ActionFilters actionFilters,
IndexNameExpressionResolver indexNameExpressionResolver) |
logDeprecatedSetting, logRemovedSetting, nodeName
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
execute, execute, execute, execute
doExecute, doExecute, getIndexShard, registerRequestHandlers, resolveRequest, retryPrimaryException, sendReplicaRequest
globalBlockLevel, indexBlockLevel, locationToSync, newReplicasProxy, syncOperationResultOrThrow
public static final java.lang.String ACTION_NAME
@Inject public TransportShardBulkAction(Settings settings, TransportService transportService, ClusterService clusterService, IndicesService indicesService, ThreadPool threadPool, ShardStateAction shardStateAction, MappingUpdatedAction mappingUpdatedAction, UpdateHelper updateHelper, ActionFilters actionFilters, IndexNameExpressionResolver indexNameExpressionResolver)
protected TransportRequestOptions transportOptions()
transportOptions
in class TransportReplicationAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>
protected BulkShardResponse newResponseInstance()
newResponseInstance
in class TransportReplicationAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>
protected boolean resolveIndex()
TransportReplicationAction
resolveIndex
in class TransportReplicationAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>
public TransportWriteAction.WritePrimaryResult<BulkShardRequest,BulkShardResponse> shardOperationOnPrimary(BulkShardRequest request, IndexShard primary) throws java.lang.Exception
TransportWriteAction
shardOperationOnPrimary
in class TransportWriteAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>
request
- the request to the primary shardprimary
- the primary shard to perform the operation onprimary
shard according to the Request
refresh policyjava.lang.Exception
public static TransportWriteAction.WritePrimaryResult<BulkShardRequest,BulkShardResponse> performOnPrimary(BulkShardRequest request, IndexShard primary, UpdateHelper updateHelper, java.util.function.LongSupplier nowInMillisSupplier, MappingUpdatePerformer mappingUpdater) throws java.lang.Exception
java.lang.Exception
public TransportWriteAction.WriteReplicaResult<BulkShardRequest> shardOperationOnReplica(BulkShardRequest request, IndexShard replica) throws java.lang.Exception
TransportWriteAction
shardOperationOnReplica
in class TransportWriteAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>
request
- the request to the replica shardreplica
- the replica shard to perform the operation onreplica
shard according to the ReplicaRequest
refresh policyjava.lang.Exception
public static Translog.Location performOnReplica(BulkShardRequest request, IndexShard replica) throws java.lang.Exception
java.lang.Exception