Return-Path: 
 <user-return-6375-apmail-cassandra-user-archive=cassandra.apache.org@cassandra.apache.org>
Delivered-To: apmail-cassandra-user-archive@www.apache.org
Received: (qmail 34738 invoked from network); 3 Jun 2010 08:01:22 -0000
Received: from unknown (HELO mail.apache.org) (140.211.11.3)
  by 140.211.11.9 with SMTP; 3 Jun 2010 08:01:22 -0000
Received: (qmail 17020 invoked by uid 500); 3 Jun 2010 08:01:21 -0000
Delivered-To: apmail-cassandra-user-archive@cassandra.apache.org
Received: (qmail 16986 invoked by uid 500); 3 Jun 2010 08:01:21 -0000
Mailing-List: contact user-help@cassandra.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:user-help@cassandra.apache.org>
List-Unsubscribe: <mailto:user-unsubscribe@cassandra.apache.org>
List-Post: <mailto:user@cassandra.apache.org>
List-Id: <user.cassandra.apache.org>
Reply-To: user@cassandra.apache.org
Delivered-To: mailing list user@cassandra.apache.org
Received: (qmail 16977 invoked by uid 99); 3 Jun 2010 08:01:21 -0000
Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136)
    by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 03 Jun 2010 08:01:21 +0000
X-ASF-Spam-Status: No, hits=0.0 required=10.0
	tests=AWL,SPF_PASS
X-Spam-Check-By: apache.org
Received-SPF: pass (athena.apache.org: local policy)
Received: from [111.67.198.66] (HELO supertool.net.cn) (111.67.198.66)
    by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 03 Jun 2010 08:01:16 +0000
Received: from [192.168.1.113] by supertool.net.cn
	(MDaemon PRO v9.6.1)
	with ESMTP id md50000168538.msg
	for <user@cassandra.apache.org>; Thu, 03 Jun 2010 16:00:52 +0800
Subject: Re: [***SPAM*** ] problem when trying to get_range_slice()
From: Shuai Yuan <yuanshuai@supertool.net.cn>
To: user@cassandra.apache.org
In-Reply-To: <1275551834.7724.54.camel@supertool-2907-01>
References: <1275551834.7724.54.camel@supertool-2907-01>
Content-Type: text/plain; charset="GB18030"
Date: Thu, 03 Jun 2010 16:01:02 +0800
Message-ID: <1275552062.7724.56.camel@supertool-2907-01>
Mime-Version: 1.0
X-Mailer: Evolution 2.28.3 
Content-Transfer-Encoding: 8bit
X-Authenticated-Sender: yuanshuai@supertool.net.cn
X-Spam-Processed: supertool.net.cn, Thu, 03 Jun 2010 16:00:52 +0800
	(not processed: message from valid local sender)
X-Lookup-Warning: EHLO lookup on [192.168.1.113] does not match
 219.142.138.203
X-Lookup-Warning: SMTP connection lookup on 219.142.138.203 does not match
 219.142.138.203
X-MDRemoteIP: 219.142.138.203
X-Return-Path: yuanshuai@supertool.net.cn
X-Envelope-From: yuanshuai@supertool.net.cn
X-MDaemon-Deliver-To: user@cassandra.apache.org

more info:

CL = ONE,

replica = 2,

and when I tried to monitor the disk_io with iostat I get almost 0MB/s
read & 0% CPU on the machine the scan-data app started on.

Thanks!

-------- ԭʼ�ż� --------
������: Shuai Yuan <yuanshuai@supertool.net.cn>
�ռ���: user@cassandra.apache.org
����: [***SPAM*** ] problem when trying to get_range_slice()
����: Thu, 03 Jun 2010 15:57:14 +0800

Hi all,

----my env----

6 servers with about 200GB data.

data structure,

64B rowkey + (5B column)*20, 
rowkey and column.value are all random bytes from a-z,A-Z,0-9

----problem----

when I tried iterate over the data in the storage, I always get
org::apache::cassandra::TimedOutException
(RpcTimeout = 2minutes)

----questions----

1.How could I iterate over my data then?

2.In the code below, I gave key_start/end/count twice, one for
get_range_slice() and the other for SlicePreditor. Are they the same?

Thanks!

----scan-data application----

	CassandraFactory factory(argv[1], 9160);
	tr1::shared_ptr<Cassandra> client(factory.create());

	Keyspace *key_space = client->getKeyspace("campaign");

	map<string, vector<Column> > mResult;
	ColumnParent cp;
	SlicePredicate sp;
	string szStart, szEnd;
	uint32_t uCount = 100; //try to retrieve 100 keys?

	szStart =
"0000000000000000000000000000000000000000000000000000000000000000";
	szEnd =
"1000000000000000000000000000000000000000000000000000000000000000";

	cp.column_family = "test_col";

	sp.__isset.slice_range = true;
	sp.slice_range.start =
"0000000000000000000000000000000000000000000000000000000000000000";
	sp.slice_range.finish =
"1000000000000000000000000000000000000000000000000000000000000000";
	sp.slice_range.count = 100;

	try {
		mResult = key_space->getRangeSlice(cp, sp, szStart, szEnd,
uCount); //by libcassandra, mainly invoking get_range_slice()

		/* then iterate the result and output */
			}
		}
	} catch (org::apache::cassandra::InvalidRequestException &ire) {
		cout << ire.why << endl;
		delete key_space;
		return 1;
	}

	return 0;

-- 
Kevin Yuan
www.yuan-shuai.info