Package org.elasticsearch.action.bulk

Class TransportSingleItemBulkWriteAction<Request extends ReplicatedWriteRequest<Request>,Response extends ReplicationResponse & WriteResponse>

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

org.elasticsearch.action.support.TransportAction<Request,Response>

org.elasticsearch.action.support.replication.TransportReplicationAction<Request,ReplicaRequest,Response>

org.elasticsearch.action.support.replication.TransportWriteAction<Request,Request,Response>

org.elasticsearch.action.bulk.TransportSingleItemBulkWriteAction<Request,Response>

Direct Known Subclasses:

TransportDeleteAction, TransportIndexAction

@Deprecated
public abstract class TransportSingleItemBulkWriteAction<Request extends ReplicatedWriteRequest<Request>,Response extends ReplicationResponse & WriteResponse>
extends TransportWriteAction<Request,Request,Response>

Deprecated.

use transport bulk action directly

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.OperationTransportHandler, TransportReplicationAction.PrimaryOperationTransportHandler, TransportReplicationAction.PrimaryResult<ReplicaRequest extends ReplicationRequest<ReplicaRequest>,Response extends ReplicationResponse>, TransportReplicationAction.ReplicaOperationTransportHandler, TransportReplicationAction.ReplicaResponse, TransportReplicationAction.ReplicaResult, TransportReplicationAction.ReplicasProxy, TransportReplicationAction.RetryOnReplicaException

Field Summary

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

clusterService, executor, indicesService, shardStateAction, transportOptions, transportPrimaryAction, transportReplicaAction, transportService

Fields inherited from class org.elasticsearch.action.support.TransportAction

actionName, indexNameExpressionResolver, taskManager, threadPool

Fields inherited from class org.elasticsearch.common.component.AbstractComponent

logger

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	TransportSingleItemBulkWriteAction(Settings settings, java.lang.String actionName, TransportService transportService, ClusterService clusterService, IndicesService indicesService, ThreadPool threadPool, ShardStateAction shardStateAction, ActionFilters actionFilters, IndexNameExpressionResolver indexNameExpressionResolver, java.util.function.Supplier<Request> request, java.util.function.Supplier<Request> replicaRequest, java.lang.String executor, TransportBulkAction bulkAction, TransportShardBulkAction shardBulkAction)	Deprecated.

Method Summary

Modifier and Type	Method	Description
protected void	doExecute(Task task, Request request, ActionListener<Response> listener)	Deprecated.
protected TransportWriteAction.WritePrimaryResult<Request,Response>	shardOperationOnPrimary(Request request, IndexShard primary)	Deprecated. Called on the primary with a reference to the primary IndexShard to modify.
protected TransportWriteAction.WriteReplicaResult<Request>	shardOperationOnReplica(Request replicaRequest, IndexShard replica)	Deprecated. Called once per replica with a reference to the replica IndexShard to modify.
static BulkRequest	toSingleItemBulkRequest(ReplicatedWriteRequest request)	Deprecated.
static <Response extends ReplicationResponse & WriteResponse> ActionListener<BulkResponse>	wrapBulkResponse(ActionListener<Response> listener)	Deprecated.

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

globalBlockLevel, indexBlockLevel, locationToSync, newReplicasProxy, syncOperationResultOrThrow

Methods inherited from class org.elasticsearch.action.support.replication.TransportReplicationAction

acquirePrimaryOperationPermit, acquireReplicaOperationPermit, doExecute, getIndexShard, newResponseInstance, registerRequestHandlers, resolveIndex, resolveRequest, retryPrimaryException, sendReplicaRequest, transportOptions

Methods inherited from class org.elasticsearch.action.support.TransportAction

execute, execute, execute, execute

Methods inherited from class java.lang.Object

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

Constructor Detail

TransportSingleItemBulkWriteAction

protected TransportSingleItemBulkWriteAction(Settings settings,
                                             java.lang.String actionName,
                                             TransportService transportService,
                                             ClusterService clusterService,
                                             IndicesService indicesService,
                                             ThreadPool threadPool,
                                             ShardStateAction shardStateAction,
                                             ActionFilters actionFilters,
                                             IndexNameExpressionResolver indexNameExpressionResolver,
                                             java.util.function.Supplier<Request> request,
                                             java.util.function.Supplier<Request> replicaRequest,
                                             java.lang.String executor,
                                             TransportBulkAction bulkAction,
                                             TransportShardBulkAction shardBulkAction)

Deprecated.

Method Detail

doExecute

protected void doExecute(Task task,
                         Request request,
                         ActionListener<Response> listener)

Deprecated.

Overrides:

doExecute in class TransportReplicationAction<Request extends ReplicatedWriteRequest<Request>,Request extends ReplicatedWriteRequest<Request>,Response extends ReplicationResponse & WriteResponse>

shardOperationOnPrimary

protected TransportWriteAction.WritePrimaryResult<Request,Response> shardOperationOnPrimary(Request request,
                                                                                                  IndexShard primary)
                                                                                           throws java.lang.Exception

Deprecated.

Description copied from class: TransportWriteAction

Called on the primary with a reference to the primary IndexShard to modify.

Specified by:

shardOperationOnPrimary in class TransportWriteAction<Request extends ReplicatedWriteRequest<Request>,Request extends ReplicatedWriteRequest<Request>,Response extends ReplicationResponse & WriteResponse>

Parameters:

request - the request to the primary shard

primary - the primary shard to perform the operation on

Returns:

the result of the operation on primary, including current translog location and operation response and failure async refresh is performed on the primary shard according to the Request refresh policy

Throws:

java.lang.Exception

shardOperationOnReplica

protected TransportWriteAction.WriteReplicaResult<Request> shardOperationOnReplica(Request replicaRequest,
                                                                                   IndexShard replica)
                                                                            throws java.lang.Exception

Deprecated.

Description copied from class: TransportWriteAction

Called once per replica with a reference to the replica IndexShard to modify.

Specified by:

shardOperationOnReplica in class TransportWriteAction<Request extends ReplicatedWriteRequest<Request>,Request extends ReplicatedWriteRequest<Request>,Response extends ReplicationResponse & WriteResponse>

Parameters:

replicaRequest - the request to the replica shard

replica - the replica shard to perform the operation on

Returns:

the result of the operation on replica, including current translog location and operation response and failure async refresh is performed on the replica shard according to the ReplicaRequest refresh policy

Throws:

java.lang.Exception

wrapBulkResponse

public static <Response extends ReplicationResponse & WriteResponse> ActionListener<BulkResponse> wrapBulkResponse(ActionListener<Response> listener)

Deprecated.

toSingleItemBulkRequest

public static BulkRequest toSingleItemBulkRequest(ReplicatedWriteRequest request)

Deprecated.