Return-Path: X-Original-To: apmail-cassandra-user-archive@www.apache.org Delivered-To: apmail-cassandra-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 6620FDE85 for ; Fri, 7 Dec 2012 13:37:49 +0000 (UTC) Received: (qmail 81150 invoked by uid 500); 7 Dec 2012 13:37:46 -0000 Delivered-To: apmail-cassandra-user-archive@cassandra.apache.org Received: (qmail 81119 invoked by uid 500); 7 Dec 2012 13:37:46 -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 81106 invoked by uid 99); 7 Dec 2012 13:37:45 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 07 Dec 2012 13:37:45 +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 (nike.apache.org: domain of 0x6e6562@gmail.com designates 209.85.214.44 as permitted sender) Received: from [209.85.214.44] (HELO mail-bk0-f44.google.com) (209.85.214.44) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 07 Dec 2012 13:37:36 +0000 Received: by mail-bk0-f44.google.com with SMTP id w11so249188bku.31 for ; Fri, 07 Dec 2012 05:37:16 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=content-type:content-transfer-encoding:subject:from:message-id:date :to:mime-version:x-mailer; bh=DrQ4ZwTtln69PLt5aFKztwgTd3UUwUZ5lFdl82gnY0k=; b=QMJbYVRvJnCa/pjMP2Ufd+OZoyNyJIbIf5EjlXBkvaoShLdmvBaoB5nO4ETrm7Pfxo M8kG2R1Tq0rXzeOiJ17aO85w0XRIY+St3h5AAqCriuIcI+MRXthwRksXFQSW8OXUtyVY uvX9AX+ZAGByHb5tDLV1cCtpo2RZcwHyr5/A6sf81TTqhXpkX9XUqdKjC9vgQHs5xa/l Wvkg6fm3BuPqj5PEG47pkwBECvuNMNlGZvH7OYDEIPSG5lg4v2HOgK7b1uUVRVdMSNY7 hfZx56wDPe/JvA8TBs4xiGZJVoQmzRMJ9M33REL4WffCadqieTpdb+DfSK+wiblm8DOT XCBw== Received: by 10.204.8.143 with SMTP id h15mr1887458bkh.115.1354887436175; Fri, 07 Dec 2012 05:37:16 -0800 (PST) Received: from [10.8.31.122] (smwoki-lupubpool-1-450.wifi.virginmedia.com. [82.13.97.194]) by mx.google.com with ESMTPS id m20sm9106622bkw.4.2012.12.07.05.37.08 (version=SSLv3 cipher=OTHER); Fri, 07 Dec 2012 05:37:15 -0800 (PST) Content-Type: text/plain; charset=us-ascii Content-Transfer-Encoding: quoted-printable Subject: Batch mutation streaming From: Ben Hood <0x6e6562@gmail.com> Message-Id: Date: Fri, 7 Dec 2012 13:34:43 +0000 To: "user@cassandra.apache.org" Mime-Version: 1.0 (1.0) X-Mailer: iPhone Mail (10A523) X-Virus-Checked: Checked by ClamAV on apache.org Hi, I'd like my app to stream a large number of events into Cassandra that origi= nate from the same network input stream. If I create one batch mutation, can= I just keep appending events to the Cassandra batch until I'm done, or are t= here some practical considerations about doing this (e.g. too much stuff buf= fering up on the client or server side, visibility of the data within the ba= tch that hasn't been closed by the client yet)? Barring any discussion about= atomicity, if I were able to stream a largish source into Cassandra, what w= ould happen if the client crashed and didn't close the batch? Or is this kin= d of thing just a normal occurrence that Cassandra has to be aware of anyway= ? Cheers, Ben=