Retrieve Rows for specified keys in order

[altanis]

I am trying to retrieve the Row objects for a List of keys, in
StorageProxy. I accomplish this in two phases: at first I make a List of
ReadCommands, one for each key, and then I give this list to
readProtocol().

My problem is that the List returned by readProtocol() has many Rows in
different indices than the List of ReadCommands, and so I cannot directly
associate the results with the keys.

I had previously done this by retrieving the Rows one by one (one call to
ReadProtocol for each key), but that was too slow and I am trying to avoid
it. I could loop through the results and match the keys, but that would
also be too slow.

Is there any way to guarantee that readProtocol()'s results will
correspond to its input?

Alexander

Build failed in Hudson: Cassandra-0.7 #205

[Apache Hudson Server]

See 

Changes:

[brandonwilliams] Allow removetoken to be called on nodes already leaving the 
ring.
Patch by brandonwilliams, reviewed by jbellis for CASSANDRA-1900

--
[...truncated 769 lines...]
A 
interface/thrift/gen-java/org/apache/cassandra/thrift/RowPredicate.java
AU
interface/thrift/gen-java/org/apache/cassandra/thrift/ConsistencyLevel.java
AU
interface/thrift/gen-java/org/apache/cassandra/thrift/ColumnOrSuperColumn.java
A interface/thrift/gen-java/org/apache/cassandra/thrift/KsDef.java
AUinterface/thrift/gen-java/org/apache/cassandra/thrift/Column.java
AUinterface/thrift/gen-java/org/apache/cassandra/thrift/TokenRange.java
A 
interface/thrift/gen-java/org/apache/cassandra/thrift/AuthenticationException.java
AUinterface/cassandra.thrift
A ivy.xml
A lib
A lib/guava-r05.jar
AUlib/concurrentlinkedhashmap-lru-1.1.jar
AUlib/high-scale-lib.jar
A lib/commons-cli-1.1.jar
AUlib/jug-2.0.0.jar
AUlib/antlr-3.1.3.jar
A lib/avro-1.4.0-fixes.jar
AUlib/jetty-6.1.21.jar
A lib/commons-codec-1.2.jar
A lib/jackson-mapper-asl-1.4.0.jar
A lib/snakeyaml-1.6.jar
A lib/commons-collections-3.2.1.jar
A lib/libthrift-0.5.jar
AUlib/servlet-api-2.5-20081211.jar
A lib/jackson-core-asl-1.4.0.jar
A lib/licenses
AUlib/licenses/log4j-1.2.16.txt
A lib/licenses/slf4j-log4j12-1.6.1.txt
AUlib/licenses/guava-r05.txt
AUlib/licenses/concurrentlinkedhashmap-lru-1.1.txt
A lib/licenses/high-scale-lib.txt
AUlib/licenses/commons-cli-1.1.txt
A lib/licenses/antlr-3.1.3.txt
A lib/licenses/jug-2.0.0.txt
AUlib/licenses/avro-1.3.1-dev.txt
A lib/licenses/jetty-6.1.21.txt
AUlib/licenses/commons-codec-1.2.txt
AUlib/licenses/jackson-mapper-asl-1.4.0.txt
A lib/licenses/snakeyaml-1.6.txt
AUlib/licenses/commons-collections-3.2.1.txt
AUlib/licenses/libthrift-0.5.txt
AUlib/licenses/jackson-core-asl-1.4.0.txt
A lib/licenses/servlet-api-2.5-20081211.txt
A lib/licenses/slf4j-api-1.6.1.txt
AUlib/licenses/commons-lang-2.4.txt
AUlib/licenses/json-simple-1.1.txt
A lib/licenses/jetty-util-6.1.21.txt
A lib/licenses/jline-0.9.94.txt
AUlib/slf4j-api-1.6.1.jar
A lib/commons-lang-2.4.jar
A lib/json-simple-1.1.jar
AUlib/jetty-util-6.1.21.jar
A lib/jline-0.9.94.jar
A lib/avro-1.4.0-sources-fixes.jar
A lib/log4j-1.2.16.jar
AUlib/slf4j-log4j12-1.6.1.jar
A redhat
A redhat/cassandra
A redhat/cassandra.conf
A redhat/default
A redhat/apache-cassandra.spec
A redhat/cassandra.in.sh
A bin
AUbin/clustertool
A bin/config-converter.bat
AUbin/nodetool
A bin/clustertool.bat
A bin/nodetool.bat
AUbin/stop-server
AUbin/sstablekeys
A bin/sstablekeys.bat
AUbin/schematool
AUbin/cassandra
A bin/schematool.bat
AUbin/cassandra-cli
AUbin/cassandra.bat
AUbin/cassandra-cli.bat
AUbin/json2sstable
AUbin/sstable2json
A bin/config-converter
AUbin/cassandra.in.sh
A bin/json2sstable.bat
A bin/sstable2json.bat
AUREADME.txt
A .rat-excludes
 U.
At revision 1063345
[cassandra] $ /home/hudson/tools/ant/latest/bin/ant -Dversion=$BUILD_ID 
-Dcobertura.dir=/usr/share/java clean release test
Buildfile: 


clean:

maven-ant-tasks-download:
 [echo] Downloading Maven ANT Tasks...
[mkdir] Created dir: 

  [get] Getting: 
http://repo2.maven.org/maven2/org/apache/maven/maven-ant-tasks/2.1.1/maven-ant-tasks-2.1.1.jar
  [get] To: 


maven-ant-tasks-init:
[mkdir] Created dir: 


maven-ant-tasks-retrieve-build:
[artifact:dependencies] Downloading: asm/asm/3.2/asm-3.2-sources.jar from 
repository central at http://repo1.maven.org/maven2
[artifact:dependencies] Unable to locate resource in repository
[artifact:dependencies] [INFO] Unable to find resource 
'asm:asm:java-source:sources:3.2' in repository central 
(http://repo1.maven.org/maven2)
[artifact:dependencies] Downloading: asm/asm/3.2/asm-3.2-sources.jar from 
repository apache at https://repository.apache.org/content/repositories/releases
[artifact:dependencies] Unable to locate resource in repository
[artifact:dependencies] [INFO] Unable to find resource 
'as

Build failed in Hudson: Cassandra-0.7 #206

[Apache Hudson Server]

See 

Changes:

[jbellis] fix bugs in multi-DC replication
patch by ivancso; reviewed by jbellis for CASSANDRA-2051

[brandonwilliams] Fix broken build from 1900

--
[...truncated 1588 lines...]
[junit] Tests run: 1, Failures: 0, Errors: 0, Time elapsed: 0.714 sec
[junit] 
[junit] Testsuite: org.apache.cassandra.db.RowTest
[junit] Tests run: 4, Failures: 0, Errors: 0, Time elapsed: 2.451 sec
[junit] 
[junit] Testsuite: org.apache.cassandra.db.SerializationsTest
[junit] Tests run: 7, Failures: 0, Errors: 0, Time elapsed: 0.479 sec
[junit] 
[junit] Testsuite: org.apache.cassandra.db.SuperColumnTest
[junit] Tests run: 1, Failures: 0, Errors: 0, Time elapsed: 0.124 sec
[junit] 
[junit] Testsuite: org.apache.cassandra.db.TableTest
[junit] Tests run: 10, Failures: 0, Errors: 0, Time elapsed: 4.273 sec
[junit] 
[junit] Testsuite: org.apache.cassandra.db.TimeSortTest
[junit] Tests run: 2, Failures: 0, Errors: 0, Time elapsed: 6.302 sec
[junit] 
[junit] Testsuite: org.apache.cassandra.db.commitlog.CommitLogHeaderTest
[junit] Tests run: 2, Failures: 0, Errors: 0, Time elapsed: 0.439 sec
[junit] 
[junit] Testsuite: org.apache.cassandra.db.marshal.IntegerTypeTest
[junit] Tests run: 10, Failures: 0, Errors: 0, Time elapsed: 0.182 sec
[junit] 
[junit] Testsuite: org.apache.cassandra.db.marshal.TimeUUIDTypeTest
[junit] Tests run: 6, Failures: 0, Errors: 0, Time elapsed: 0.069 sec
[junit] 
[junit] Testsuite: org.apache.cassandra.db.marshal.TypeCompareTest
[junit] Tests run: 5, Failures: 0, Errors: 0, Time elapsed: 0.073 sec
[junit] 
[junit] Testsuite: org.apache.cassandra.db.marshal.TypeValidationTest
[junit] Tests run: 9, Failures: 0, Errors: 0, Time elapsed: 0.293 sec
[junit] 
[junit] Testsuite: org.apache.cassandra.db.migration.SerializationsTest
[junit] Tests run: 1, Failures: 0, Errors: 0, Time elapsed: 0.857 sec
[junit] 
[junit] Testsuite: org.apache.cassandra.dht.BootStrapperTest
[junit] Tests run: 4, Failures: 0, Errors: 0, Time elapsed: 1.861 sec
[junit] 
[junit] - Standard Error -
[junit]  WARN 17:27:29,999 Generated random token 
Token(bytes[9155b78df1891ad1e3c26bd5be4b346c]). Random tokens will result in an 
unbalanced ring; see http://wiki.apache.org/cassandra/Operations
[junit] -  ---
[junit] Testsuite: org.apache.cassandra.dht.ByteOrderedPartitionerTest
[junit] Tests run: 5, Failures: 0, Errors: 0, Time elapsed: 1.123 sec
[junit] 
[junit] Testsuite: 
org.apache.cassandra.dht.CollatingOrderPreservingPartitionerTest
[junit] Tests run: 7, Failures: 0, Errors: 0, Time elapsed: 1.331 sec
[junit] 
[junit] Testsuite: org.apache.cassandra.dht.OrderPreservingPartitionerTest
[junit] Tests run: 6, Failures: 0, Errors: 0, Time elapsed: 1.151 sec
[junit] 
[junit] Testsuite: org.apache.cassandra.dht.RandomPartitionerTest
[junit] Tests run: 5, Failures: 0, Errors: 0, Time elapsed: 0.786 sec
[junit] 
[junit] Testsuite: org.apache.cassandra.dht.RangeTest
[junit] Tests run: 13, Failures: 0, Errors: 0, Time elapsed: 0.448 sec
[junit] 
[junit] Testsuite: org.apache.cassandra.gms.ArrivalWindowTest
[junit] Tests run: 1, Failures: 0, Errors: 0, Time elapsed: 0.113 sec
[junit] 
[junit] Testsuite: org.apache.cassandra.gms.GossipDigestTest
[junit] Tests run: 1, Failures: 0, Errors: 0, Time elapsed: 0.052 sec
[junit] 
[junit] Testsuite: org.apache.cassandra.gms.SerializationsTest
[junit] Tests run: 2, Failures: 0, Errors: 0, Time elapsed: 0.446 sec
[junit] 
[junit] Testsuite: org.apache.cassandra.hadoop.ColumnFamilyInputFormatTest
[junit] Tests run: 1, Failures: 0, Errors: 0, Time elapsed: 0.183 sec
[junit] 
[junit] Testsuite: org.apache.cassandra.io.BloomFilterTrackerTest
[junit] Tests run: 3, Failures: 0, Errors: 0, Time elapsed: 0.384 sec
[junit] 
[junit] Testsuite: org.apache.cassandra.io.CompactSerializerTest
[junit] Tests run: 2, Failures: 0, Errors: 0, Time elapsed: 1.275 sec
[junit] 
[junit] Testsuite: org.apache.cassandra.io.LazilyCompactedRowTest
[junit] Tests run: 5, Failures: 0, Errors: 0, Time elapsed: 20.594 sec
[junit] 
[junit] Testsuite: org.apache.cassandra.io.sstable.LegacySSTableTest
[junit] Tests run: 1, Failures: 0, Errors: 0, Time elapsed: 1.346 sec
[junit] 
[junit] - Standard Error -
[junit]  WARN 17:28:09,435 Invalid file '.svn' in data directory 

[junit]  WARN 17:28:10,027 Invalid file '.svn' in data directory 

Hudson build is back to normal : Cassandra-0.7 #207

[Apache Hudson Server]

See 

[VOTE] 0.7.1

[Eric Evans]

Shall we?  I propose the following artifacts for release as 0.7.1.

SVN:
https://svn.apache.org/repos/asf/cassandra/branches/cassandra-0.7@r1063491
0.7.1 artifacts: http://people.apache.org/~eevans

The will remain open for 72 hours, (longer if need be).


[1]: http://goo.gl/4cJkq (CHANGES.txt)
[2]: http://goo.gl/SBGPA (NEWS.txt)

-- 
Eric Evans
eev...@rackspace.com

Re: [VOTE] 0.7.1

[Stephen Connolly]

I'll stage artifacts in central tomorrow AM GMT

On 25 January 2011 23:01, Eric Evans  wrote:
>
> Shall we?  I propose the following artifacts for release as 0.7.1.
>
> SVN:
> https://svn.apache.org/repos/asf/cassandra/branches/cassandra-0.7@r1063491
> 0.7.1 artifacts: http://people.apache.org/~eevans
>
> The will remain open for 72 hours, (longer if need be).
>
>
> [1]: http://goo.gl/4cJkq (CHANGES.txt)
> [2]: http://goo.gl/SBGPA (NEWS.txt)
>
> --
> Eric Evans
> eev...@rackspace.com
>
>

Fwd: CFP - Berlin Buzzwords 2011 - Search, Score, Scale

[David G. Boney]

This might interest the Cassandra community.
-
Sincerely,
David G. Boney
dbon...@semanticartifacts.com
http://www.semanticartifacts.com




Begin forwarded message:

> From: Isabel Drost 
> Date: January 25, 2011 2:53:28 PM CST
> To: u...@mahout.apache.org
> Cc: gene...@lucene.apache.org, gene...@hadoop.apache.org, 
> u...@hbase.apache.org, solr-u...@lucene.apache.org, 
> java-u...@lucene.apache.org, u...@nutch.apache.org
> Subject: CFP - Berlin Buzzwords 2011 - Search, Score, Scale
> Reply-To: u...@mahout.apache.org
> Reply-To: isa...@apache.org
> 
> This is to announce the Berlin Buzzwords 2011. The second edition of the 
> successful conference on scalable and open search, data processing and data 
> storage in Germany, taking place in Berlin.
> 
> Call for Presentations Berlin Buzzwords
>http://berlinbuzzwords.de
>   Berlin Buzzwords 2011 - Search, Store, Scale
> 6/7 June 2011
> The event will comprise presentations on scalable data processing. We invite 
> you to submit talks on the topics:
>* IR / Search - Lucene, Solr, katta or comparable solutions
>* NoSQL - like CouchDB, MongoDB, Jackrabbit, HBase and others
>* Hadoop - Hadoop itself, MapReduce, Cascading or Pig and relatives
>* Closely related topics not explicitly listed above are welcome. We are
>  looking for presentations on the implementation of the systems 
> themselves,
>  real world applications and case studies.
> 
> Important Dates (all dates in GMT +2)
>* Submission deadline: March 1st 2011, 23:59 MEZ
>* Notification of accepted speakers: March 22th, 2011, MEZ.
>* Publication of final schedule: April 5th, 2011.
>* Conference: June 6/7. 2011
> High quality, technical submissions are called for, ranging from principles 
> to practice. We are looking for real world use cases, background on the 
> architecture of specific projects and a deep dive into architectures built on 
> top of e.g. Hadoop clusters.
> 
> Proposals should be submitted at http://berlinbuzzwords.de/content/cfp-0 no 
> later than March 1st, 2011. Acceptance notifications will be sent out soon 
> after the submission deadline. Please include your name, bio and email, the 
> title of the talk, a brief abstract in English language. Please indicate 
> whether you want to give a lightning (10min), short (20min) or long (40min) 
> presentation and indicate the level of experience with the topic your 
> audience should have (e.g. whether your talk will be suitable for newbies or 
> is targeted for experienced users.) If you'd like to pitch your brand new 
> product in your talk, please let us know as well - there will be extra space 
> for presenting new ideas, awesome products and great new projects.
> 
> The presentation format is short. We will be enforcing the schedule 
> rigorously.
> 
> If you are interested in sponsoring the event (e.g. we would be happy to 
> provide videos after the event, free drinks for attendees as well as an 
> after-show party), please contact us.
> 
> Follow @hadoopberlin on Twitter for updates. Tickets, news on the conference, 
> and the final schedule are be published at http://berlinbuzzwords.de.
> 
> Program Chairs: Isabel Drost, Jan Lehnardt, and Simon Willnauer.
> Please re-distribute this CfP to people who might be interested.
> If you are local and wish to meet us earlier, please note that this Thursday 
> evening there will be an Apache Hadoop Get Together (videos kindly sponsored 
> by Cloudera, venue kindly provided for free by Zanox) featuring talks on 
> Apache Hadoop in production as well as news on current Apache Lucene 
> developments.
> 
> Contact us at:
> 
> newthinking communications 
> GmbH Schönhauser Allee 6/7 
> 10119 Berlin, 
> Germany 
> Julia Gemählich
> Isabel Drost 
> +49(0)30-9210 596