Return-Path: Delivered-To: apmail-cassandra-user-archive@www.apache.org Received: (qmail 158 invoked from network); 14 Oct 2010 18:55:44 -0000 Received: from unknown (HELO mail.apache.org) (140.211.11.3) by 140.211.11.9 with SMTP; 14 Oct 2010 18:55:44 -0000 Received: (qmail 23724 invoked by uid 500); 14 Oct 2010 18:55:42 -0000 Delivered-To: apmail-cassandra-user-archive@cassandra.apache.org Received: (qmail 23705 invoked by uid 500); 14 Oct 2010 18:55:42 -0000 Mailing-List: contact user-help@cassandra.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@cassandra.apache.org Delivered-To: mailing list user@cassandra.apache.org Received: (qmail 23697 invoked by uid 99); 14 Oct 2010 18:55:42 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 14 Oct 2010 18:55:42 +0000 X-ASF-Spam-Status: No, hits=2.2 required=10.0 tests=HTML_MESSAGE,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: local policy) Received: from [38.104.202.190] (HELO webmail.diamondnotch.com) (38.104.202.190) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 14 Oct 2010 18:55:34 +0000 Received: from DNLEXCH01.corp.diamondnotch.com ([192.168.164.25]) by DNLEXCH01 ([192.168.164.25]) with mapi; Thu, 14 Oct 2010 14:55:13 -0400 From: Koert Kuipers To: "'user@cassandra.apache.org'" Date: Thu, 14 Oct 2010 14:55:12 -0400 Subject: deletion Thread-Topic: deletion Thread-Index: Actr0VSCk9hVXO56QRmkaw6+/GfTWA== Message-ID: <6143522CDE27514BB78C92BCD7190003032DA81224@DNLEXCH01> Accept-Language: en-US Content-Language: en-US X-MS-Has-Attach: X-MS-TNEF-Correlator: acceptlanguage: en-US Content-Type: multipart/alternative; boundary="_000_6143522CDE27514BB78C92BCD7190003032DA81224DNLEXCH01_" MIME-Version: 1.0 X-Virus-Checked: Checked by ClamAV on apache.org --_000_6143522CDE27514BB78C92BCD7190003032DA81224DNLEXCH01_ Content-Type: text/plain; charset="us-ascii" Content-Transfer-Encoding: quoted-printable Hello All, I am testing Cassandra 0.7 with the Avro api on a single machine as a finan= cial time series server, so my setup looks something like this: keyspace =3D timeseries, column family =3D tickdata, key =3D ticker, super = column =3D field (price, volume, high, low), column =3D timestamp. So a single value, say a price of 140.72 for IBM today at 14:00 would be st= ored as tickdata["IBM"]["price"]["2010-10-14 14:00"] =3D 140.72 (well of course eve= rything needs to be encoded properly but you get the point). My subcomparator type is TimeUUIDType so that I can do queries over time ra= nges. Inserting and querying all work reasonably well so far. But sometimes I have a need to wipe out all the data for all day. To be mor= e precise: I need to delete the stored values for all keys (tickers) and al= l super-columns (fields) for a given time period (condition on column). How= would I go about doing that? First a multiget_slice and then a remove comm= and for each value? Or am I missing an easier way? Is slice deletion within batch_mutate still scheduled to be implemented? Thanks for your help, Koert --_000_6143522CDE27514BB78C92BCD7190003032DA81224DNLEXCH01_ Content-Type: text/html; charset="us-ascii" Content-Transfer-Encoding: quoted-printable

Hello All,

I am testing Cassandra 0.7 with the Avro api on a single machine as a financial time series server, so my setup looks something like= this:

keyspace =3D timeseries, column family =3D tickdata, key= =3D ticker, super column =3D field (price, volume, high, low), column =3D times= tamp.

So a single value, say a price of 140.72 for IBM today a= t 14:00 would be stored as

tickdata[“IBM”][“price”][“= 2010-10-14 14:00”] =3D 140.72 (well of course everything needs to be encoded pro= perly but you get the point).

My subcomparator type is TimeUUIDType so that I can do queries over time ranges. Inserting and querying all work reasonably well s= o far.

But sometimes I have a need to wipe out all the data for= all day. To be more precise: I need to delete the stored values for all keys (t= ickers) and all super-columns (fields) for a given time period (condition on column= ). How would I go about doing that? First a multiget_slice and then a remove comma= nd for each value? Or am I missing an easier way?

Is slice deletion within batch_mutate still scheduled to= be implemented?

Thanks for your help,

Koert

--_000_6143522CDE27514BB78C92BCD7190003032DA81224DNLEXCH01_--