svn commit: r1197494 - /cassandra/branches/cassandra-1.0/src/java/org/apache/cassandra/db/RetriedSliceFromReadCommand.java

[sl...@apache.org]

Author: slebresne
Date: Fri Nov  4 10:44:50 2011
New Revision: 1197494

URL: http://svn.apache.org/viewvc?rev=1197494&view=rev
Log:
Add missing file from previous commit

Added:
    cassandra/branches/cassandra-1.0/src/java/org/apache/cassandra/db/RetriedSliceFromReadCommand.java

Added: cassandra/branches/cassandra-1.0/src/java/org/apache/cassandra/db/RetriedSliceFromReadCommand.java
URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-1.0/src/java/org/apache/cassandra/db/RetriedSliceFromReadCommand.java?rev=1197494&view=auto
==============================================================================
--- cassandra/branches/cassandra-1.0/src/java/org/apache/cassandra/db/RetriedSliceFromReadCommand.java (added)
+++ cassandra/branches/cassandra-1.0/src/java/org/apache/cassandra/db/RetriedSliceFromReadCommand.java Fri Nov  4 10:44:50 2011
@@ -0,0 +1,76 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.cassandra.db;
+
+import java.nio.ByteBuffer;
+
+import org.apache.cassandra.db.filter.QueryPath;
+import org.apache.cassandra.thrift.ColumnParent;
+import org.apache.cassandra.utils.ByteBufferUtil;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class RetriedSliceFromReadCommand extends SliceFromReadCommand
+{
+    static final Logger logger = LoggerFactory.getLogger(RetriedSliceFromReadCommand.class);
+    public final int originalCount;
+
+    public RetriedSliceFromReadCommand(String table, ByteBuffer key, ColumnParent column_parent, ByteBuffer start,
+            ByteBuffer finish, boolean reversed, int originalCount, int count)
+    {
+        super(table, key, column_parent, start, finish, reversed, count);
+        this.originalCount = originalCount;
+    }
+
+    public RetriedSliceFromReadCommand(String table, ByteBuffer key, QueryPath path, ByteBuffer start,
+            ByteBuffer finish, boolean reversed, int originalCount, int count)
+    {
+        super(table, key, path, start, finish, reversed, count);
+        this.originalCount = originalCount;
+    }
+
+    @Override
+    public ReadCommand copy()
+    {
+        ReadCommand readCommand = new RetriedSliceFromReadCommand(table, key, queryPath, start, finish, reversed, originalCount, count);
+        readCommand.setDigestQuery(isDigestQuery());
+        return readCommand;
+    }
+
+    @Override
+    public int getRequestedCount()
+    {
+        return originalCount;
+    }
+
+    @Override
+    public String toString()
+    {
+        return "RetriedSliceFromReadCommand(" +
+               "table='" + table + '\'' +
+               ", key='" + ByteBufferUtil.bytesToHex(key) + '\'' +
+               ", column_parent='" + queryPath + '\'' +
+               ", start='" + getComparator().getString(start) + '\'' +
+               ", finish='" + getComparator().getString(finish) + '\'' +
+               ", reversed=" + reversed +
+               ", originalCount=" + originalCount +
+               ", count=" + count +
+               ')';
+    }
+
+}