Package org.apache.hadoop.hbase.coprocessor

Class MultiRowMutationEndpoint

java.lang.Object
org.apache.hadoop.hbase.protobuf.generated.MultiRowMutationProtos.MultiRowMutationService
org.apache.hadoop.hbase.coprocessor.MultiRowMutationEndpoint
All Implemented Interfaces:
com.google.protobuf.Service, Coprocessor, RegionCoprocessor
@LimitedPrivate("Coprocesssor") @Evolving public class MultiRowMutationEndpoint extends org.apache.hadoop.hbase.protobuf.generated.MultiRowMutationProtos.MultiRowMutationService implements RegionCoprocessor
This class implements atomic multi row transactions using HRegion.mutateRowsWithLocks(Collection, Collection, long, long) and Coprocessor endpoints. We can also specify some conditions to perform conditional update. Defines a protocol to perform multi row transactions. See MultiRowMutationEndpoint for the implementation.
See HRegion.mutateRowsWithLocks(Collection, Collection, long, long) for details and limitations.
Example: Put p = new Put(row1); Delete d = new Delete(row2); Increment i = new Increment(row3); Append a = new Append(row4); ... Mutate m1 = ProtobufUtil.toMutate(MutateType.PUT, p); Mutate m2 = ProtobufUtil.toMutate(MutateType.DELETE, d); Mutate m3 = ProtobufUtil.toMutate(MutateType.INCREMENT, i); Mutate m4 = ProtobufUtil.toMutate(MutateType.Append, a); MutateRowsRequest.Builder mrmBuilder = MutateRowsRequest.newBuilder(); mrmBuilder.addMutationRequest(m1); mrmBuilder.addMutationRequest(m2); mrmBuilder.addMutationRequest(m3); mrmBuilder.addMutationRequest(m4); // We can also specify conditions to preform conditional update mrmBuilder.addCondition(ProtobufUtil.toCondition(row, FAMILY, QUALIFIER, CompareOperator.EQUAL, value, TimeRange.allTime())); CoprocessorRpcChannel channel = t.coprocessorService(ROW); MultiRowMutationService.BlockingInterface service = MultiRowMutationService.newBlockingStub(channel); MutateRowsRequest mrm = mrmBuilder.build(); MutateRowsResponse response = service.mutateRows(null, mrm); // We can get the result of the conditional update boolean processed = response.getProcessed();

  • Nested Class Summary

    Nested classes/interfaces inherited from class org.apache.hadoop.hbase.protobuf.generated.MultiRowMutationProtos.MultiRowMutationService

    org.apache.hadoop.hbase.protobuf.generated.MultiRowMutationProtos.MultiRowMutationService.BlockingInterface, org.apache.hadoop.hbase.protobuf.generated.MultiRowMutationProtos.MultiRowMutationService.Interface, org.apache.hadoop.hbase.protobuf.generated.MultiRowMutationProtos.MultiRowMutationService.Stub

    Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.Coprocessor

    Coprocessor.State

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    private RegionCoprocessorEnvironment
    env
     
    private static final org.slf4j.Logger
    LOGGER
     

    Fields inherited from interface org.apache.hadoop.hbase.Coprocessor

    PRIORITY_HIGHEST, PRIORITY_LOWEST, PRIORITY_SYSTEM, PRIORITY_USER, VERSION

  • Constructor Summary

    Constructors
    Constructor
    Description
    MultiRowMutationEndpoint()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    private void
    checkFamily(Region region, byte[] family)
     
    Iterable<com.google.protobuf.Service>
    getServices()
    Coprocessor endpoints providing protobuf services should override this method.
    private boolean
    matches(CompareOperator op, int compareResult)
     
    private boolean
    matches(Region region, org.apache.hadoop.hbase.protobuf.generated.ClientProtos.Condition condition)
     
    void
    mutateRows(com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.protobuf.generated.MultiRowMutationProtos.MutateRowsRequest request, com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.protobuf.generated.MultiRowMutationProtos.MutateRowsResponse> done)
     
    void
    start(CoprocessorEnvironment env)
    Stores a reference to the coprocessor environment provided by the RegionCoprocessorHost from the region where this coprocessor is loaded.
    void
    stop(CoprocessorEnvironment env)
    Called by the CoprocessorEnvironment during it's own shutdown to stop the coprocessor.

    Methods inherited from class org.apache.hadoop.hbase.protobuf.generated.MultiRowMutationProtos.MultiRowMutationService

    callMethod, getDescriptor, getDescriptorForType, getRequestPrototype, getResponsePrototype, newBlockingStub, newReflectiveBlockingService, newReflectiveService, newStub

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface org.apache.hadoop.hbase.coprocessor.RegionCoprocessor

    getBulkLoadObserver, getEndpointObserver, getRegionObserver