Class ReplicationOperation<Request extends ReplicationRequest<Request>,ReplicaRequest extends ReplicationRequest<ReplicaRequest>,PrimaryResultT extends ReplicationOperation.PrimaryResult<ReplicaRequest>>

java.lang.Object
org.elasticsearch.action.support.replication.ReplicationOperation<Request,ReplicaRequest,PrimaryResultT>

public class ReplicationOperation<Request extends ReplicationRequest<Request>,ReplicaRequest extends ReplicationRequest<ReplicaRequest>,PrimaryResultT extends ReplicationOperation.PrimaryResult<ReplicaRequest>> extends Object
  • Constructor Details

  • Method Details

    • execute

      public void execute() throws Exception
      The execution is based on a RefCountingListener that encapsulates the pending sub-operations in this operation. A new listener is acquired when the following sub-operations start and triggered when they complete:
      • The operation on the primary
      • The operation on each replica
      • Coordination of the operation as a whole. This prevents the operation from terminating early if we haven't started any replica operations and the primary finishes.
      Throws:
      Exception
    • checkActiveShardCount

      protected String checkActiveShardCount()
      Checks whether we can perform a write based on the required active shard count setting. Returns **null* if OK to proceed, or a string describing the reason to stop