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 final String	ACTION_NAME
static final ActionType<BulkShardResponse>	TYPE

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

executorSelector, 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

Modifier and Type	Method	Description
protected void	dispatchedShardOperationOnPrimary(BulkShardRequest request, IndexShard primary, ActionListener<TransportReplicationAction.PrimaryResult<BulkShardRequest,BulkShardResponse>> listener)
protected void	dispatchedShardOperationOnReplica(BulkShardRequest request, IndexShard replica, ActionListener<TransportReplicationAction.ReplicaResult> listener)
protected BulkShardResponse	newResponseInstance(StreamInput in)
static void	performOnPrimary(BulkShardRequest request, IndexShard primary, UpdateHelper updateHelper, LongSupplier nowInMillisSupplier, MappingUpdatePerformer mappingUpdater, Consumer<ActionListener<Void>> waitForMappingUpdate, ActionListener<TransportReplicationAction.PrimaryResult<BulkShardRequest,BulkShardResponse>> listener, ThreadPool threadPool, String executorName)
static Translog.Location	performOnReplica(BulkShardRequest request, IndexShard replica)
protected int	primaryOperationCount(BulkShardRequest request)
protected long	primaryOperationSize(BulkShardRequest request)
protected int	replicaOperationCount(BulkShardRequest request)
protected long	replicaOperationSize(BulkShardRequest request)
protected TransportRequestOptions	transportOptions()

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

Methods inherited from class java.lang.Object

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

Field Details

ACTION_NAME

public static final String ACTION_NAME

See Also:

• Constant Field Values

TYPE

public static final ActionType<BulkShardResponse> TYPE

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

protected TransportRequestOptions transportOptions()

Overrides:

transportOptions in class TransportReplicationAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>

newResponseInstance

protected BulkShardResponse newResponseInstance(StreamInput in)
                                         throws IOException

Specified by:

newResponseInstance in class TransportReplicationAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>

Throws:

IOException

dispatchedShardOperationOnPrimary

protected void dispatchedShardOperationOnPrimary(BulkShardRequest request,
 IndexShard primary,
 ActionListener<TransportReplicationAction.PrimaryResult<BulkShardRequest,BulkShardResponse>> listener)

Specified by:

dispatchedShardOperationOnPrimary in class TransportWriteAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>

primaryOperationSize

protected long primaryOperationSize(BulkShardRequest request)

Overrides:

primaryOperationSize in class TransportWriteAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>

primaryOperationCount

protected int primaryOperationCount(BulkShardRequest request)

Overrides:

primaryOperationCount in class TransportWriteAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>

performOnPrimary

public static void performOnPrimary(BulkShardRequest request,
 IndexShard primary,
 UpdateHelper updateHelper,
 LongSupplier nowInMillisSupplier,
 MappingUpdatePerformer mappingUpdater,
 Consumer<ActionListener<Void>> waitForMappingUpdate,
 ActionListener<TransportReplicationAction.PrimaryResult<BulkShardRequest,BulkShardResponse>> listener,
 ThreadPool threadPool,
 String executorName)

dispatchedShardOperationOnReplica

protected void dispatchedShardOperationOnReplica(BulkShardRequest request,
 IndexShard replica,
 ActionListener<TransportReplicationAction.ReplicaResult> listener)

Specified by:

dispatchedShardOperationOnReplica in class TransportWriteAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>

replicaOperationSize

protected long replicaOperationSize(BulkShardRequest request)

Overrides:

replicaOperationSize in class TransportWriteAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>

replicaOperationCount

protected int replicaOperationCount(BulkShardRequest request)

Overrides:

replicaOperationCount in class TransportWriteAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>

performOnReplica

public static Translog.Location performOnReplica(BulkShardRequest request,
 IndexShard replica)
                                          throws Exception

Throws:

Exception