Return-Path: X-Original-To: apmail-accumulo-dev-archive@www.apache.org Delivered-To: apmail-accumulo-dev-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id AFDCACB2E for ; Thu, 18 Jul 2013 18:21:59 +0000 (UTC) Received: (qmail 8650 invoked by uid 500); 18 Jul 2013 18:21:59 -0000 Delivered-To: apmail-accumulo-dev-archive@accumulo.apache.org Received: (qmail 8601 invoked by uid 500); 18 Jul 2013 18:21:58 -0000 Mailing-List: contact dev-help@accumulo.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@accumulo.apache.org Delivered-To: mailing list dev@accumulo.apache.org Received: (qmail 8591 invoked by uid 99); 18 Jul 2013 18:21:58 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 18 Jul 2013 18:21:58 +0000 X-ASF-Spam-Status: No, hits=1.5 required=5.0 tests=HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of hshreedharan@cloudera.com designates 209.85.160.41 as permitted sender) Received: from [209.85.160.41] (HELO mail-pb0-f41.google.com) (209.85.160.41) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 18 Jul 2013 18:21:52 +0000 Received: by mail-pb0-f41.google.com with SMTP id rp16so3496668pbb.14 for ; Thu, 18 Jul 2013 11:21:29 -0700 (PDT) X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=google.com; s=20120113; h=date:from:to:message-id:in-reply-to:references:subject:x-mailer :mime-version:content-type:x-gm-message-state; bh=d/OBmty8N9ltJH+sHNrRKtyTWUzbbofaUW6Q9lw9BsQ=; b=Hx//sWgQpKOF8pa89RnccI7lKew4ICnXMybZXc63OxL87TVDEnzURGXrQa0oODmTPL fU+HBnPMfzbMD7XKrJ101wOtO7KW/kZPdyNp2knFt2SciFujGKDUDJ9dcwcwHXyRCTO5 Js18LuuE9N3oD574ytYUcOI8Ku03Iovaq7KrZLmtNexIHMHFpUPmVGcQCDr5gSoHNJUW jhr/ZG2sjUgjKJPjvWpwIu4IeLXKR42/P8VfOcw79Z7r33r3Gzq+eSVwCXTmZlhjXYpM KSAoAfCpIwaYQi2Kq3m7Fvt8OfX6CiQ9czoAzNpWblnhsRRdUIuhonuj1Jbm2t9FYajW wXKg== X-Received: by 10.68.189.228 with SMTP id gl4mr13485386pbc.57.1374171689579; Thu, 18 Jul 2013 11:21:29 -0700 (PDT) Received: from [172.22.1.152] ([65.50.196.130]) by mx.google.com with ESMTPSA id xl3sm15066518pbb.17.2013.07.18.11.21.28 for (version=TLSv1 cipher=RC4-SHA bits=128/128); Thu, 18 Jul 2013 11:21:28 -0700 (PDT) Date: Thu, 18 Jul 2013 11:21:28 -0700 From: Hari Shreedharan To: dev@accumulo.apache.org Message-ID: <02725F1F7F444800A69B368FAB97499B@cloudera.com> In-Reply-To: References: <6312D1E9-22AC-49BF-8661-13B6F3608DEF@clearedgeit.com> Subject: Re: Accumulo flume sink X-Mailer: sparrow 1.6.4 (build 1178) MIME-Version: 1.0 Content-Type: multipart/alternative; boundary="51e83228_100f8fca_21f3" X-Gm-Message-State: ALoCoQnLCW0VxjkPUIh09/U9mUiUMvcnCVlGVN1SNK/wQdeBFBHMeOApPAzAwx8B/Z3E3pOZRmb7 X-Virus-Checked: Checked by ClamAV on apache.org --51e83228_100f8fca_21f3 Content-Type: text/plain; charset="utf-8" Content-Transfer-Encoding: 7bit Content-Disposition: inline Hi Don, I'd be glad to review and commit this to the Apache Flume project alongside the HBase sink, if you choose to consider Flume as an option. There have been sinks writing to many systems (like HBase, ElasticSearch, Solr etc) committed to Flume and an Accumulo Sink would be welcome! Thanks, Hari Thanks, Hari On Thursday, July 18, 2013 at 11:16 AM, Sean Busbey wrote: > In general, I think it's a good idea to push things into the external > projects. Granted, this depends on the mindset of various communities. > > > On Thu, Jul 18, 2013 at 1:08 PM, Donald Miner wrote: > > > Should we try to do this for other things like the pig storage mechanisms? > > Has anyone else tried getting accumulo specific stuff into the tools? > > > > On Jul 18, 2013, at 1:46 PM, Sean Busbey wrote: > > > > > Hi Matt! > > > > > > How about contributing the sink to Flume directly? As Jon mentioned, the > > > Accumulo API is pretty stable, and they're generally receptive to new > > > > > > > sinks > > > (there's also an existing HBase sink). > > > > > > > > > On Mon, Jul 15, 2013 at 1:03 PM, Matthew Molek > > wrote: > > > > > > > The idea of a writing flume sink for accumulo was suggested last year in > > > > ACCUMULO-811, but I don't think any activity ever came of it. > > > > > > > > https://issues.apache.org/jira/browse/ACCUMULO-811 > > > > > > > > I've rewritten the original code (which wasn't on the Jira, but I got a > > > > copy of) to mirror the way the flume sink for hbase is organized, and to > > > > work with flume-ng. > > > > > > > > My code is up on github: > > https://github.com/mpmolek/flume-ng-accumulo-sink > > > > > > > > I'd welcome any comments, and if there is interest, I'd be happy to have > > > > this added to contrib. > > > > > > > > -Matt > > > > > > > > -- > > > > This communication is the property of ClearEdge IT Solutions, LLC and > > > > > > > > > > > may > > > > contain confidential and/or privileged information. Any review, > > > > retransmissions, dissemination or other use of or taking of any action > > > > > > > > > > > in > > > > reliance upon this information by persons or entities other than the > > > > intended recipient is prohibited. If you receive this communication in > > > > error, please immediately notify the sender and destroy all copies of > > > > > > > > > > > the > > > > communication and any attachments. > > > > > > > > > > > > > > > -- > > > Sean Busbey > > > Senior Solutions Architect > > > Cloudera, Inc. > > > Phone: MAN-VS-BEARD > > > > > > > > > -- > > This communication is the property of ClearEdge IT Solutions, LLC and may > > contain confidential and/or privileged information. Any review, > > retransmissions, dissemination or other use of or taking of any action in > > reliance upon this information by persons or entities other than the > > intended recipient is prohibited. If you receive this communication in > > error, please immediately notify the sender and destroy all copies of the > > communication and any attachments. > > > > > > > -- > Sean Busbey > Senior Solutions Architect > Cloudera, Inc. > Phone: MAN-VS-BEARD > > --51e83228_100f8fca_21f3--