Uploaded image for project: 'HBase'
  1. HBase
  2. HBASE-4210

Allow coprocessor to interact with batches per region sent from a client

    XMLWordPrintableJSON

Details

    • New Feature
    • Status: Closed
    • Major
    • Resolution: Fixed
    • 0.94.6, 0.95.0
    • 0.98.0, 0.94.6, 0.95.0
    • None
    • None
    • Reviewed
    • Hide
      Adds a pre/post CP hooks to deal with batches of Puts and Deletes rather than individual Put/Delete.
      The preBatchMutate hook will be called after aquiring locks on all the rows which are involved in a batch.
      Also by this time the timestamps for Mutation will be applied at RS. So from this hook CP can get the batch of Mutations getting applied and their timestamps which will be getting applied
      CP also can bypass any of the Mutation from getting applied by setting its OperationStatus as SUCCESS/FAILURE.
      postBatchMutate hook will be called after write to memstore and append and sync to WAL.
      Show
      Adds a pre/post CP hooks to deal with batches of Puts and Deletes rather than individual Put/Delete. The preBatchMutate hook will be called after aquiring locks on all the rows which are involved in a batch. Also by this time the timestamps for Mutation will be applied at RS. So from this hook CP can get the batch of Mutations getting applied and their timestamps which will be getting applied CP also can bypass any of the Mutation from getting applied by setting its OperationStatus as SUCCESS/FAILURE. postBatchMutate hook will be called after write to memstore and append and sync to WAL.

    Description

      Currently the coprocessor write hooks -

      {pre|post} {Put|Delete}

      - are strictly one row|cell operations.
      It might be a good idea to allow a coprocessor to deal with batches of puts and deletes as they arrive from the client.

      Attachments

        1. 4210_Trunk-V3.patch
          22 kB
          Ted Yu
        2. HBASE-4210_94.patch
          13 kB
          Anoop Sam John
        3. HBASE-4210_94-V2.patch
          12 kB
          Anoop Sam John
        4. HBASE-4210_94-V3.patch
          22 kB
          Anoop Sam John
        5. HBASE-4210_94-V4.patch
          22 kB
          Anoop Sam John
        6. HBASE-4210_94-V5.patch
          22 kB
          Anoop Sam John
        7. HBASE-4210_Trunk.patch
          22 kB
          Anoop Sam John
        8. HBASE-4210_Trunk-V2.patch
          22 kB
          Anoop Sam John
        9. HBASE-4210_Trunk-V3.patch
          22 kB
          Anoop Sam John
        10. hbase-4210-addendum.patch
          18 kB
          Enis Soztutar

        Issue Links

          Activity

            People

              anoopsamjohn Anoop Sam John
              larsh Lars Hofhansl
              Votes:
              2 Vote for this issue
              Watchers:
              17 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: