Hi HBase community,
Can anyone confirm that the method incrementColumnValue is implemented
correctly?
I'm talking about mainly the deprecated method:
@Deprecated
@Override
public long incrementColumnValue(final byte [] row, final byte [] family,
final byte [] qualifier, final long
Hi, Jerry
Which version of HBase is it?
-Vlad
On Tue, Jun 9, 2015 at 8:05 AM, Jerry Lam chiling...@gmail.com wrote:
Hi HBase community,
Can anyone confirm that the method incrementColumnValue is implemented
correctly?
I'm talking about mainly the deprecated method:
@Deprecated
I see code in this formation in 0.98 branch.
Looking at the unit tests which exercise incrementColumnValue(), they all
call:
public long incrementColumnValue(final byte [] row, final byte [] family,
final byte [] qualifier, final long amount)
Possibly because the one mentioned by Jerry
at the unit tests which exercise incrementColumnValue(), they all
call:
public long incrementColumnValue(final byte [] row, final byte [] family,
final byte [] qualifier, final long amount)
Possibly because the one mentioned by Jerry is deprecated.
FYI
On Tue, Jun 9, 2015 at 8:49 AM
Regards,
Jerry
On Tue, Jun 9, 2015 at 12:03 PM, Ted Yu yuzhih...@gmail.com wrote:
I see code in this formation in 0.98 branch.
Looking at the unit tests which exercise incrementColumnValue(), they all
call:
public long incrementColumnValue(final byte [] row, final byte []
family
,
Jerry
On Tue, Jun 9, 2015 at 12:03 PM, Ted Yu yuzhih...@gmail.com wrote:
I see code in this formation in 0.98 branch.
Looking at the unit tests which exercise incrementColumnValue(), they
all
call:
public long incrementColumnValue(final byte [] row, final
incrementColumnValue(), they
all
call:
public long incrementColumnValue(final byte [] row, final byte []
family,
final byte [] qualifier, final long amount)
Possibly because the one mentioned by Jerry is deprecated.
FYI
On Tue, Jun 9, 2015 at 8:49 AM, Vladimir
wrote:
I see code in this formation in 0.98 branch.
Looking at the unit tests which exercise incrementColumnValue(),
they
all
call:
public long incrementColumnValue(final byte [] row, final byte []
family,
final byte [] qualifier, final long amount
(with threading and without), but the threaded solution is
causing the problem.
We are processing log files with PUTs in the Map and a followup
incrementColumnValue() to a separate counts table in the Reducer. The
reduce phase uses multi-threading. The Reducer initializes an HTablePool
in the setup
in an MR job it would be very helpful. We are testing both
implementations (with threading and without), but the threaded solution is
causing the problem.
We are processing log files with PUTs in the Map and a followup
incrementColumnValue() to a separate counts table in the Reducer. The
reduce
. Reading through the HTable docs suggests not to use single
HTable
instance for updates, if it's true how can incrementColumnValue
provide
thread safety?
thanks
--
陈加俊 项目经理
优讯时代(北京)网络技术有限公司
优讯网 www.uuwatch.com
地址:北京市海淀区上地信息路2号D栋412
电话:010-82895510
传真:010
different threads from different
parts of
the app. Reading through the HTable docs suggests not to use
single
HTable
instance for updates, if it's true how can incrementColumnValue
provide
thread safety?
thanks
--
陈加俊 项目经理
优讯时代(北京)网络技术有限公司
优
instance for updates, if it's true how can incrementColumnValue provide
thread safety?
thanks
incrementColumnValue provide
thread safety?
thanks
the HTable docs suggests not to use single
HTable
instance for updates, if it's true how can incrementColumnValue provide
thread safety?
thanks
service.
This
singleton service is called from different threads from different
parts of
the app. Reading through the HTable docs suggests not to use single
HTable
instance for updates, if it's true how can incrementColumnValue provide
thread safety?
thanks
threads from different
parts of
the app. Reading through the HTable docs suggests not to use single
HTable
instance for updates, if it's true how can incrementColumnValue
provide
thread safety?
thanks
I have an HTable instance instantiated as part of a singleton service. This
singleton service is called from different threads from different parts of
the app. Reading through the HTable docs suggests not to use single HTable
instance for updates, if it's true how can incrementColumnValue provide
through the HTable docs suggests not to use single HTable
instance for updates, if it's true how can incrementColumnValue provide
thread safety?
thanks
.invoke(Unknown Source)
at sun.reflec...
I guess I have tried all possible combinations of datatypesI could not
even find a decent example of incrementColumnValue()
)
at sun.reflect.GeneratedMethodAccessor17.invoke(Unknown Source)
at sun.reflec...
I guess I have tried all possible combinations of datatypesI could not
even find a decent example of incrementColumnValue()
Hi,
It looks like the problem is that the initial value you're inserting in the
column is an int, while HTable#incrementColumnValue() expects a long.
Instead of:
I enter data by :-
theput.add(Bytes.toBytes(uid),Bytes.toBytes(1), 130108782L + t,
Bytes.toBytes(10))
try:
theput.add
tried all possible combinations of datatypesI could
not
even find a decent example of incrementColumnValue()
Thanks Jesse. Changing the 10 to 10L made it work.
On Tue, Mar 29, 2011 at 8:59 AM, Jesse Hutton jesse.hut...@gmail.comwrote:
Hi,
It looks like the problem is that the initial value you're inserting in the
column is an int, while HTable#incrementColumnValue() expects a long.
Instead
.
On Tue, Mar 29, 2011 at 8:59 AM, Jesse Hutton jesse.hut...@gmail.comwrote:
Hi,
It looks like the problem is that the initial value you're inserting in
the column is an int, while HTable#incrementColumnValue() expects a long.
Instead of:
I enter data by :-
theput.add(Bytes.toBytes(uid
in
the column is an int, while HTable#incrementColumnValue() expects a
long.
Instead of:
I enter data by :-
theput.add(Bytes.toBytes(uid),Bytes.toBytes(1), 130108782L + t,
Bytes.toBytes(10))
try:
theput.add(Bytes.toBytes(uid),Bytes.toBytes(1), 130108782L + t
.
You can also summarize your data and use a secondary process to
execute a roll up of ICVs... if the number isnt too massive this might
be acceptable.
On Tue, Jan 11, 2011 at 4:07 PM, Billy Pearson
sa...@pearsonwholesale.com wrote:
Is there a way to make a mapreduce job and use incrementColumnValue
Is there a way to make a mapreduce job and use incrementColumnValue in place
of Put?
I am trying to move a job over from thrift and have to be able to use
incrementColumnValue
as a output but I can not seams to work it out with out calling HTable every
map.
small example would be nice
of ICVs... if the number isnt too massive this might
be acceptable.
On Tue, Jan 11, 2011 at 4:07 PM, Billy Pearson
sa...@pearsonwholesale.com wrote:
Is there a way to make a mapreduce job and use incrementColumnValue in place
of Put?
I am trying to move a job over from thrift and have
29 matches
Mail list logo