Return-Path: X-Original-To: apmail-streams-dev-archive@minotaur.apache.org Delivered-To: apmail-streams-dev-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 59FFB10A37 for ; Mon, 16 Sep 2013 00:12:12 +0000 (UTC) Received: (qmail 43762 invoked by uid 500); 16 Sep 2013 00:12:12 -0000 Delivered-To: apmail-streams-dev-archive@streams.apache.org Received: (qmail 43738 invoked by uid 500); 16 Sep 2013 00:12:12 -0000 Mailing-List: contact dev-help@streams.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@streams.incubator.apache.org Delivered-To: mailing list dev@streams.incubator.apache.org Received: (qmail 43720 invoked by uid 99); 16 Sep 2013 00:12:10 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 16 Sep 2013 00:12:10 +0000 X-ASF-Spam-Status: No, hits=-0.5 required=5.0 tests=FREEMAIL_ENVFROM_END_DIGIT,RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of jletourneau80@gmail.com designates 209.85.223.177 as permitted sender) Received: from [209.85.223.177] (HELO mail-ie0-f177.google.com) (209.85.223.177) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 16 Sep 2013 00:12:05 +0000 Received: by mail-ie0-f177.google.com with SMTP id qd12so5892614ieb.8 for ; Sun, 15 Sep 2013 17:11:45 -0700 (PDT) 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=1JFR+qF698ZXDzcDKjUVkeW+BQH8K2RaBmIXCK2kdeY=; b=HV8pi9AqBXoS2C2APFEr5QYtath2kx8nK/nfd7x5j6kiqI7BigQqyyju3SMuOBGKOO 1K3+tHU+pUmxGkexHaOIjR1GOVY9J9nSbjqA8x1TVxKN18St8f7evTcQ7pwNptHxFLCQ EALl1B1kIr9lFe6X2bfAG52V/ldGCVTbSiJfG7OMd+9IgDGgppgPtbXFlDQj1MZ1SM2u ywgBc4Vq3Mkh6wV2pmMUUUXSsP5TEcD8K+KivCAot4t6CD4+lTWrO6nIhk5DmAuHIbSD UFCKiU4CD8+pqDGUg+I9QEoJiePamz5oxGyOkQnxk4cUyrkljZtJ4njU2DDR7SasGYPX e4TA== MIME-Version: 1.0 X-Received: by 10.50.20.3 with SMTP id j3mr5358443ige.11.1379290305099; Sun, 15 Sep 2013 17:11:45 -0700 (PDT) Received: by 10.64.223.110 with HTTP; Sun, 15 Sep 2013 17:11:45 -0700 (PDT) In-Reply-To: References: Date: Sun, 15 Sep 2013 20:11:45 -0400 Message-ID: Subject: Re: More Cassandra Branch Updates From: Jason Letourneau To: "dev@streams.incubator.apache.org" Content-Type: text/plain; charset=ISO-8859-1 X-Virus-Checked: Checked by ClamAV on apache.org +1! Sounds like good stuff On Fri, Sep 13, 2013 at 7:16 AM, Matt Franklin wrote: > On Mon, Sep 9, 2013 at 4:27 PM, Danny Sullivan wrote: > >> The cassandra branch under >> https://svn.apache.org/repos/asf/incubator/streams/branches/cassandra/ is >> at the point where I'd like to start the conversation about merging it with >> trunk. It works by taking in all activity off the activemq and storing it >> in the cassandra database. The new activity aggregator has a method >> distributeToSubscribers which runs on a timer every 30 seconds and pushes >> relevant activity to all subscribers based on the filters they've specified >> and last time that their streams were updated. >> For my branch I used the DataStax java driver. I'd like to keep a couple >> chips in the CQL driver pot, at least until Intravert has a stable release >> and the Cassandra wiki retracts the recommendation of exclusive use of CQL >> clients. >> I've been using cassandra 1.2 for running it. >> I'd like to hear what everyone thinks and if there's support, perhaps we >> can merge the branch. >> > > +1 for merging > > >> Danny