We are using 1.1.2.2.4.0.0-169 version.
Yes, by additional logging, I determined that postPut method is not triggered
for the update.
Here is the code sinppet:
List<Put> puts = new ArrayList<>(dataObjects.size());
Table table = connection.getTable(TableName.valueOf(qualifiedTableName);
for (DataObjectType dataObject : dataObjects) {
Put put = new Put(..);
//Create family
//Create qualifier
put.add(family, qualifier, dataObject.getRowKey());
puts.add(put);
}
table.put(puts);
table.close();
thanks,
veena.
-----Original Message-----
From: Anoop John [mailto:[email protected]]
Sent: Monday, October 17, 2016 2:06 AM
To: [email protected]
Subject: Re: Hbase Coprocessor postPut not triggered for
Ya what API used for this update op u mention?
-Anoop-
On Mon, Oct 17, 2016 at 9:25 AM, Ted Yu <[email protected]> wrote:
> Which release of hbase are you using ?
>
> How did you determine that coprocessor's postPut method is not
> triggered for the update ? By additional logging ?
>
> Can you give code snippet around the update ?
>
> Thanks
>
> On Sun, Oct 16, 2016 at 8:48 PM, Begar, Veena <[email protected]> wrote:
>
>> Hello,
>>
>> We are using coprocessor feature by extending BaseRegionServer class.
>>
>> In postPut method, we send a message to kafka. Soon after creating a
>> row, we update it. We see it triggering postPut for creating row, but
>> for the subsequent update, it doesn't trigger postPut method:
>> void createAndUpdate(.. )
>> {
>> //create new row - Hbase put method -- coprocessor's postPut is
>> triggered //update the row - Hbase put method -- coprocessor's
>> postPut method is not triggered .. . ...
>> }
>>
>> Please let me know why postPut method is not triggered for the 2nd
>> put call.
>>
>> Thanks,
>> Veena.
>>
