Return-Path: X-Original-To: apmail-cassandra-commits-archive@www.apache.org Delivered-To: apmail-cassandra-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 779F8F708 for ; Wed, 27 Mar 2013 20:36:03 +0000 (UTC) Received: (qmail 28993 invoked by uid 500); 27 Mar 2013 20:36:03 -0000 Delivered-To: apmail-cassandra-commits-archive@cassandra.apache.org Received: (qmail 28970 invoked by uid 500); 27 Mar 2013 20:36:03 -0000 Mailing-List: contact commits-help@cassandra.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@cassandra.apache.org Delivered-To: mailing list commits@cassandra.apache.org Received: (qmail 28960 invoked by uid 99); 27 Mar 2013 20:36:03 -0000 Received: from tyr.zones.apache.org (HELO tyr.zones.apache.org) (140.211.11.114) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 27 Mar 2013 20:36:03 +0000 Received: by tyr.zones.apache.org (Postfix, from userid 65534) id 0277C828394; Wed, 27 Mar 2013 20:36:02 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: jbellis@apache.org To: commits@cassandra.apache.org Message-Id: <0b393d81c7d847b28daa3d093ed772e1@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: git commit: Deserialize to arrays instead of trees patch by jbellis; reviewed by slebresne for CASSANDRA-5389 Date: Wed, 27 Mar 2013 20:36:02 +0000 (UTC) Updated Branches: refs/heads/trunk 4c348c422 -> d21556f4f Deserialize to arrays instead of trees patch by jbellis; reviewed by slebresne for CASSANDRA-5389 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/d21556f4 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/d21556f4 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/d21556f4 Branch: refs/heads/trunk Commit: d21556f4f53d4b59c3e2ae1d3571fb1fba6bf5ed Parents: 4c348c4 Author: Jonathan Ellis Authored: Wed Mar 27 11:27:20 2013 -0500 Committer: Jonathan Ellis Committed: Wed Mar 27 11:27:34 2013 -0500 ---------------------------------------------------------------------- .../cassandra/db/ColumnFamilySerializer.java | 6 +++--- src/java/org/apache/cassandra/db/ReadResponse.java | 2 +- src/java/org/apache/cassandra/db/Row.java | 6 +++--- src/java/org/apache/cassandra/db/RowMutation.java | 2 +- 4 files changed, 8 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/d21556f4/src/java/org/apache/cassandra/db/ColumnFamilySerializer.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/db/ColumnFamilySerializer.java b/src/java/org/apache/cassandra/db/ColumnFamilySerializer.java index 3c88b54..0a1db4e 100644 --- a/src/java/org/apache/cassandra/db/ColumnFamilySerializer.java +++ b/src/java/org/apache/cassandra/db/ColumnFamilySerializer.java @@ -88,15 +88,15 @@ public class ColumnFamilySerializer implements IVersionedSerializer if (!isDigest) { // This is coming from a remote host - row = Row.serializer.deserialize(in, version, ColumnSerializer.Flag.FROM_REMOTE, ArrayBackedSortedColumns.factory()); + row = Row.serializer.deserialize(in, version, ColumnSerializer.Flag.FROM_REMOTE); } return isDigest ? new ReadResponse(ByteBuffer.wrap(digest)) : new ReadResponse(row); http://git-wip-us.apache.org/repos/asf/cassandra/blob/d21556f4/src/java/org/apache/cassandra/db/Row.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/db/Row.java b/src/java/org/apache/cassandra/db/Row.java index d6435ba..785b058 100644 --- a/src/java/org/apache/cassandra/db/Row.java +++ b/src/java/org/apache/cassandra/db/Row.java @@ -61,15 +61,15 @@ public class Row ColumnFamily.serializer.serialize(row.cf, out, version); } - public Row deserialize(DataInput in, int version, ColumnSerializer.Flag flag, ISortedColumns.Factory factory) throws IOException + public Row deserialize(DataInput in, int version, ColumnSerializer.Flag flag) throws IOException { return new Row(StorageService.getPartitioner().decorateKey(ByteBufferUtil.readWithShortLength(in)), - ColumnFamily.serializer.deserialize(in, flag, factory, version)); + ColumnFamily.serializer.deserialize(in, flag, version)); } public Row deserialize(DataInput in, int version) throws IOException { - return deserialize(in, version, ColumnSerializer.Flag.LOCAL, TreeMapBackedSortedColumns.factory()); + return deserialize(in, version, ColumnSerializer.Flag.LOCAL); } public long serializedSize(Row row, int version) http://git-wip-us.apache.org/repos/asf/cassandra/blob/d21556f4/src/java/org/apache/cassandra/db/RowMutation.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/db/RowMutation.java b/src/java/org/apache/cassandra/db/RowMutation.java index 4495dae..9f3efa0 100644 --- a/src/java/org/apache/cassandra/db/RowMutation.java +++ b/src/java/org/apache/cassandra/db/RowMutation.java @@ -280,7 +280,7 @@ public class RowMutation implements IMutation // We used to uselessly write the cf id here if (version < MessagingService.VERSION_12) ColumnFamily.serializer.deserializeCfId(in, version); - ColumnFamily cf = ColumnFamily.serializer.deserialize(in, flag, TreeMapBackedSortedColumns.factory(), version); + ColumnFamily cf = ColumnFamily.serializer.deserialize(in, flag, version); // We don't allow RowMutation with null column family, so we should never get null back. assert cf != null; return cf;