Return-Path: X-Original-To: apmail-flume-user-archive@www.apache.org Delivered-To: apmail-flume-user-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 5EA8418AC1 for ; Tue, 10 Nov 2015 14:55:37 +0000 (UTC) Received: (qmail 27165 invoked by uid 500); 10 Nov 2015 14:55:32 -0000 Delivered-To: apmail-flume-user-archive@flume.apache.org Received: (qmail 27094 invoked by uid 500); 10 Nov 2015 14:55:31 -0000 Mailing-List: contact user-help@flume.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@flume.apache.org Delivered-To: mailing list user@flume.apache.org Received: (qmail 27079 invoked by uid 99); 10 Nov 2015 14:55:31 -0000 Received: from Unknown (HELO spamd2-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 10 Nov 2015 14:55:31 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd2-us-west.apache.org (ASF Mail Server at spamd2-us-west.apache.org) with ESMTP id 58C251A28D2 for ; Tue, 10 Nov 2015 14:55:31 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 3.879 X-Spam-Level: *** X-Spam-Status: No, score=3.879 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1, FREEMAIL_REPLY=1, HTML_MESSAGE=3, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, SPF_PASS=-0.001] autolearn=disabled Authentication-Results: spamd2-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=gmail.com Received: from mx1-us-east.apache.org ([10.40.0.8]) by localhost (spamd2-us-west.apache.org [10.40.0.9]) (amavisd-new, port 10024) with ESMTP id BT7diI7W7yum for ; Tue, 10 Nov 2015 14:55:30 +0000 (UTC) Received: from mail-wm0-f53.google.com (mail-wm0-f53.google.com [74.125.82.53]) by mx1-us-east.apache.org (ASF Mail Server at mx1-us-east.apache.org) with ESMTPS id 1C4E14419E for ; Tue, 10 Nov 2015 14:55:30 +0000 (UTC) Received: by wmvv187 with SMTP id v187so11949352wmv.1 for ; Tue, 10 Nov 2015 06:55:29 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:in-reply-to:references:date:message-id:subject:from:to :content-type; bh=qi8aPEIiteNL432mOA89rrW8Bu/jV2jIGWpeq+b2m74=; b=ady+xhq6ulH4RTegxZ+dj2DpCeBnSavpZ8t2Oi1i8ZDlXbU8IaSLozYO97pdaLMa5g xgd+4AsWRP5r4pndhUoTuZIBaWEf+uDbnZDdEoRpqklOi9yfec1WqoAr2FbXxbFjiPAb 8a2FifPIVnPf/n7Y2suy226bxRYVoCAdct9J+2qDAhk172Xd805KlNLdW5dSh1n3tiYx VCN84ZjlLdGxynrWu7P3fGfZ5TRO0BOJfWDtFAQXW51wRLmALoQL14298KzpFa66LS8j 1HkaAFAR84GLBzx4sgoyRmTDSOF90/b1ieNwAwSbOJ5Xlczzn3o8Q2Qfnbs4IPagDjhs FXQw== MIME-Version: 1.0 X-Received: by 10.194.235.170 with SMTP id un10mr4519059wjc.57.1447167329317; Tue, 10 Nov 2015 06:55:29 -0800 (PST) Received: by 10.194.25.234 with HTTP; Tue, 10 Nov 2015 06:55:29 -0800 (PST) In-Reply-To: References: Date: Tue, 10 Nov 2015 14:55:29 +0000 Message-ID: Subject: Re: Hbase Sink From: Gonzalo Herreros To: user Content-Type: multipart/alternative; boundary=047d7b3a8764983cc0052430e6cf --047d7b3a8764983cc0052430e6cf Content-Type: text/plain; charset=UTF-8 I started by extending RegexHbaseEventSerializer, so I didn't have to implement the full HbaseEventSerializer Override (and call parent) configure(Context context) to get your custom configuration properties In public List getActions() throws FlumeException where you conver the On 7 November 2015 at 11:07, Rani Yaroshinski wrote: > Any pointers to the code, as sample ? > > On Sat, Nov 7, 2015 at 12:45 PM, Gonzalo Herreros > wrote: > >> I did a custom serializer that parses the event an json and the top level >> properties become columns inside a configurable column family. >> I also have a custom property to configure which fields make up the >> composite key (which I salt based on the number of regions). >> >> It shouldn't be too hard having a property that maps input fields into >> hbase cf:column names (kinda like Hive does when you map an HBase table) >> >> Regards, >> Gonzalo >> >> On 7 November 2015 at 09:17, Rani Yaroshinski > > wrote: >> >>> Hi, >>> >>> It seems a little weird, but it looks like the most simple sink you >>> would like for hbase, >>> which allows you to set key, and columns generally is missing. >>> You need to write specific custom serializer for any implementation >>> which would make >>> a sense for any production system. >>> Anyone with pointers to rellevant custom implementations which allows >>> configuration for key >>> type and value, and also for column family data. >>> >>> Regards, >>> Rani >>> >> >> > --047d7b3a8764983cc0052430e6cf Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable
I started by extending=C2=A0RegexHbaseEventSerializer, so = I didn't have to implement the full=C2=A0HbaseEventSerializer

<= /div>
Override (and call parent) configure(Context context) to get your= custom configuration properties

In

=

public List<Row> getActions() throws FlumeE= xception

where you conver the=C2=A0

On 7 November 20= 15 at 11:07, Rani Yaroshinski <rani.yaroshinski@gmail.com>= wrote:
Any point= ers to the code, as sample ?
<= div class=3D"gmail_extra">
On Sat, Nov 7, 201= 5 at 12:45 PM, Gonzalo Herreros <gherreros@gmail.com> wrot= e:
I did a custom s= erializer that parses the event an json and the top level properties become= columns inside a configurable column family.
I also have a c= ustom property to configure which fields make up the composite key (which I= salt based on the number of regions).

It shouldn&= #39;t be too hard having a property that maps input fields into hbase cf:co= lumn names (kinda like Hive does when you map an HBase table)
Regards,
Gonzalo

On 7 November 2015 at 09:17, Ran= i Yaroshinski <rani.yaroshinski@gmail.com> wrote:
Hi,

It= seems a little weird, but it looks like the most simple sink you would lik= e for hbase,
which allows you to set key, and columns generally i= s missing.
You need to write specific custom serializer for any i= mplementation which would make
a sense for any production system.=
Anyone with pointers to rellevant custom implementations which a= llows configuration for key
type and value, and also for column f= amily data.

Regards,
Rani



--047d7b3a8764983cc0052430e6cf--