+ * List mutations = ...;
+ * Put p1 = new Put(row1);
+ * Put p2 = new Put(row2);
+ * ...
+ * Mutate m1 = ProtobufUtil.toMutate(MutateType.PUT, p1);
+ * Mutate m2 = ProtobufUtil.toMutate(MutateType.PUT, p2);
+ * MultiMutateRequest.Builder mrmBuilder = MultiMutateRequest.newBuilder();
+ * mrmBuilder.addMutatationRequest(m1);
+ * mrmBuilder.addMutatationRequest(m2);
+ * CoprocessorRpcChannel channel = t.coprocessorService(ROW);
+ * MultiRowMutationService.BlockingInterface service =
+ * MultiRowMutationService.newBlockingStub(channel);
+ * MultiMutateRequest mrm = mrmBuilder.build();
+ * service.mutateRows(null, mrm);
+ *
*/
@InterfaceAudience.Public
@InterfaceStability.Evolving
-public class MultiRowMutationEndpoint extends BaseEndpointCoprocessor implements
- MultiRowMutationProtocol {
-
+public class MultiRowMutationEndpoint extends MultiRowMutationService implements
+CoprocessorService, Coprocessor {
+ private RegionCoprocessorEnvironment env;
@Override
- public void mutateRows(List