public class TransportShardBulkAction extends TransportShardReplicationOperationAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>
TransportShardReplicationOperationAction.AsyncShardOperationAction, TransportShardReplicationOperationAction.InternalRequest, TransportShardReplicationOperationAction.PrimaryOperationRequest, TransportShardReplicationOperationAction.PrimaryResponse<Response,ReplicaRequest>, TransportShardReplicationOperationAction.ReplicaOperationRequest
Modifier and Type | Field and Description |
---|---|
static String |
ACTION_NAME |
clusterService, defaultReplicationType, defaultWriteConsistencyLevel, indicesService, shardStateAction, transportOptions, transportService
actionName, threadPool
componentSettings, logger, settings
Constructor and Description |
---|
TransportShardBulkAction(Settings settings,
TransportService transportService,
ClusterService clusterService,
IndicesService indicesService,
ThreadPool threadPool,
ShardStateAction shardStateAction,
MappingUpdatedAction mappingUpdatedAction,
UpdateHelper updateHelper,
ActionFilters actionFilters) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
checkWriteConsistency() |
protected String |
executor() |
protected BulkShardRequest |
newReplicaRequestInstance() |
protected BulkShardRequest |
newRequestInstance() |
protected BulkShardResponse |
newResponseInstance() |
protected boolean |
resolveIndex() |
protected TransportShardReplicationOperationAction.PrimaryResponse<BulkShardResponse,BulkShardRequest> |
shardOperationOnPrimary(ClusterState clusterState,
TransportShardReplicationOperationAction.PrimaryOperationRequest shardRequest) |
protected void |
shardOperationOnReplica(TransportShardReplicationOperationAction.ReplicaOperationRequest shardRequest) |
protected ShardIterator |
shards(ClusterState clusterState,
TransportShardReplicationOperationAction.InternalRequest request) |
protected TransportRequestOptions |
transportOptions() |
checkGlobalBlock, checkRequestBlock, doExecute, ignoreReplicaException, ignoreReplicas, isConflictException, postPrimaryOperation, resolveRequest, retryPrimaryException
execute, execute, forceThreadedListener
nodeName
public static final String ACTION_NAME
@Inject public TransportShardBulkAction(Settings settings, TransportService transportService, ClusterService clusterService, IndicesService indicesService, ThreadPool threadPool, ShardStateAction shardStateAction, MappingUpdatedAction mappingUpdatedAction, UpdateHelper updateHelper, ActionFilters actionFilters)
protected String executor()
executor
in class TransportShardReplicationOperationAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>
protected boolean checkWriteConsistency()
checkWriteConsistency
in class TransportShardReplicationOperationAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>
protected TransportRequestOptions transportOptions()
protected BulkShardRequest newRequestInstance()
newRequestInstance
in class TransportShardReplicationOperationAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>
protected BulkShardRequest newReplicaRequestInstance()
protected BulkShardResponse newResponseInstance()
newResponseInstance
in class TransportShardReplicationOperationAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>
protected boolean resolveIndex()
resolveIndex
in class TransportShardReplicationOperationAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>
protected ShardIterator shards(ClusterState clusterState, TransportShardReplicationOperationAction.InternalRequest request)
shards
in class TransportShardReplicationOperationAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>
protected TransportShardReplicationOperationAction.PrimaryResponse<BulkShardResponse,BulkShardRequest> shardOperationOnPrimary(ClusterState clusterState, TransportShardReplicationOperationAction.PrimaryOperationRequest shardRequest)
shardOperationOnPrimary
in class TransportShardReplicationOperationAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>
protected void shardOperationOnReplica(TransportShardReplicationOperationAction.ReplicaOperationRequest shardRequest)
shardOperationOnReplica
in class TransportShardReplicationOperationAction<BulkShardRequest,BulkShardRequest,BulkShardResponse>
Copyright © 2009–2015. All rights reserved.