mapreduce get error while update HBase

2016-10-21 Thread
Hi, all I use mapreduce to update HBase data, got this error just now, and I have no idea why this happened. below is the error log: 2016-10-22 01:14:49,047 WARN [main] org.apache.hadoop.mapred.YarnChild: Exception running child : java.lang.RuntimeException:

Re: query multiple specified columns using filterlist

2016-08-04 Thread
> You can use FilterList to put the filters together: > > public FilterList(final Operator operator) { > > AND -> MUST_PASS_ALL > > On Thu, Aug 4, 2016 at 2:07 AM, 乔彦克 <qya...@gmail.com> wrote: > > > Thanks for the advice, Ted. > > I have the column pre

Re: query multiple specified columns using filterlist

2016-08-04 Thread
using ColumnPrefixFilter. > > For filtering value, consider using SingleColumnValueFilter. > > On Wed, Aug 3, 2016 at 7:52 PM, 乔彦克 <qya...@gmail.com> wrote: > > > Thanks for your reply, Ted. > > Addition, if I want to filter another column -- one or many columns with

Re: query multiple specified columns using filterlist

2016-08-03 Thread
retrieve: > > public Scan addColumn(byte [] family, byte [] qualifier) { > > w.r.t. value comparison with cf:c3 column, consider using > SingleColumnValueFilter. > > Cheers > > On Mon, Aug 1, 2016 at 6:56 PM, 乔彦克 <qya...@gmail.com> wrote: > > > Hi all, >

query multiple specified columns using filterlist

2016-08-01 Thread
Hi all, Currently I am using HBase client api to fetch data from HBase, and I want to get 3 columns (cf:c1,cf:c2,cf:c3), and some value equals cf:c3 column, But I don't know how to construct the filterList to achieve this, So How can I do with that? Any suggestion will be appreciated! Best

Re: How to serialize Result in HBase 1.0

2016-04-11 Thread
4写道: > It seems your code didn't go through. > > Please take a look at ResultSerialization and related classes. > > Cheers > > On Mon, Apr 11, 2016 at 5:29 PM, 乔彦克 <qya...@gmail.com> wrote: > > > Hi, all > > recently we upgrade our HBase cluster from cd

How to serialize Result in HBase 1.0

2016-04-11 Thread
Hi, all recently we upgrade our HBase cluster from cdh-0.94 to cdh-1.0. In 0.94 we use Result.java(implement Writable) as the map out value. [image: pasted1] but int the newer HBase version Result.java has changed, it can't be serialized any more. Is there any alternative methods to use Result