From 784d968db9655784b7ce26cadb35e15c3faa6c7e Mon Sep 17 00:00:00 2001
From: Jonathan Ellis <jbellis@apache.org>
Date: Fri, 15 May 2009 20:41:05 +0000
Subject: [PATCH] omitted to add Sandeep's SBRRC.java in last commit

git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@775321 13f79535-47bb-0310-9956-ffa450edef68
---
 .../cassandra/db/SliceByRangeReadCommand.java | 86 +++++++++++++++++++
 1 file changed, 86 insertions(+)
 create mode 100644 src/java/org/apache/cassandra/db/SliceByRangeReadCommand.java

diff --git a/src/java/org/apache/cassandra/db/SliceByRangeReadCommand.java b/src/java/org/apache/cassandra/db/SliceByRangeReadCommand.java
new file mode 100644
index 0000000000..fbce0661d2
--- /dev/null
+++ b/src/java/org/apache/cassandra/db/SliceByRangeReadCommand.java
@@ -0,0 +1,86 @@
+package org.apache.cassandra.db;
+
+import java.io.DataInputStream;
+import java.io.DataOutputStream;
+import java.io.IOException;
+
+public class SliceByRangeReadCommand extends ReadCommand {
+
+	
+	public final String columnFamily;
+	public final String startColumn;
+	public final String endColumn;
+	public final int count;
+	
+	public SliceByRangeReadCommand(String table, String key, String columnFamily, String startCol, String endCol, int count)
+	{
+		super(table, key, CMD_TYPE_GET_SLICE_BY_RANGE);
+		this.columnFamily = columnFamily;
+		this.startColumn = startCol;
+		this.endColumn = endCol;
+		this.count = count;
+	}
+	
+	@Override
+	public ReadCommand copy() 
+	{
+		ReadCommand readCommand= new SliceByRangeReadCommand(table, key, columnFamily, startColumn, endColumn,count);
+		readCommand.setDigestQuery(isDigestQuery());
+		return readCommand;
+	}
+
+	@Override
+	public String getColumnFamilyName() 
+	{
+		return columnFamily;
+	}
+
+	@Override
+	public Row getRow(Table table) throws IOException 
+	{
+		return table.getRow(key, columnFamily, startColumn, endColumn, count);
+	}
+	
+	@Override
+    public String toString()
+    {
+        return "GetSliceByNamesReadMessage(" +
+               "table='" + table + '\'' +
+               ", key='" + key + '\'' +
+               ", columnFamily='" + columnFamily + '\'' +
+               ", startColumn=" + startColumn +
+               ", endColumn=" + endColumn +
+               ')';
+    }
+}
+
+class SliceByRangeReadCommandSerializer extends ReadCommandSerializer
+{
+	@Override
+	public void serialize(ReadCommand rm, DataOutputStream dos) throws IOException
+	{
+		SliceByRangeReadCommand realRM = (SliceByRangeReadCommand)rm;
+		dos.writeBoolean(realRM.isDigestQuery());
+		dos.writeUTF(realRM.table);
+		dos.writeUTF(realRM.key);
+		dos.writeUTF(realRM.columnFamily);
+		dos.writeUTF(realRM.startColumn);
+		dos.writeUTF(realRM.endColumn);
+		dos.writeInt(realRM.count);
+	}
+
+	@Override
+	public ReadCommand deserialize(DataInputStream dis) throws IOException
+	{
+		boolean isDigest = dis.readBoolean();
+		String table = dis.readUTF();
+		String key = dis.readUTF();
+		String columnFamily = dis.readUTF();
+		String startColumn = dis.readUTF();
+		String endColumn = dis.readUTF();
+		int count = dis.readInt();
+		SliceByRangeReadCommand rm = new SliceByRangeReadCommand(table, key, columnFamily, startColumn, endColumn, count);
+		rm.setDigestQuery(isDigest);
+		return rm;
+	}
+}
\ No newline at end of file