Performs shard-level bulk (index, delete or update) operations
-
-
Field Summary
Fields
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
-
Constructor Summary
Constructors
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
protected void
protected void
static void
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,
PostWriteRefresh postWriteRefresh,
Consumer<Runnable> postWriteAction)
protected int
protected long
protected int
protected long
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 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:
-
-
-
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
-
-
-
-
-
-
-
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,
@Nullable
PostWriteRefresh postWriteRefresh,
@Nullable
Consumer<Runnable> postWriteAction)
-
-
-
-