natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

new thrift file changes 

git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@758048 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Prashant Malik 2009-03-24 22:09:21 +00:00
parent 74dcfb263c
commit c25dae0a2f
1 changed files with 25 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
src/org/apache/cassandra/service/Cassandra.java
View File

@ -18,7 +18,7 @@ import com.facebook.thrift.transport.*;
public class Cassandra {
public interface Iface extends com.facebook.fb303.FacebookService.Iface {
public interface Iface {
public List<column_t> get_slice(String tablename, String key, String columnFamily_column, int start, int count) throws CassandraException, TException;
@ -60,7 +60,7 @@ public class Cassandra {
}
public static class Client extends com.facebook.fb303.FacebookService.Client implements Iface {
public static class Client implements Iface {
public Client(TProtocol prot)
{
this(prot, prot);
@ -68,7 +68,23 @@ public class Cassandra {
public Client(TProtocol iprot, TProtocol oprot)
{
super(iprot, oprot);
iprot_ = iprot;
oprot_ = oprot;
}
protected TProtocol iprot_;
protected TProtocol oprot_;
protected int seqid_;
public TProtocol getInputProtocol()
{
return this.iprot_;
}
public TProtocol getOutputProtocol()
{
return this.oprot_;
}
public List<column_t> get_slice(String tablename, String key, String columnFamily_column, int start, int count) throws CassandraException, TException
@ -669,10 +685,9 @@ public class Cassandra {
}
}
public static class Processor extends com.facebook.fb303.FacebookService.Processor implements TProcessor {
public static class Processor implements TProcessor {
public Processor(Iface iface)
{
super(iface);
iface_ = iface;
processMap_.put("get_slice", new get_slice());
processMap_.put("get_slice_by_names", new get_slice_by_names());
@ -695,7 +710,12 @@ public class Cassandra {
processMap_.put("executeQuery", new executeQuery());
}
protected static interface ProcessFunction {
public void process(int seqid, TProtocol iprot, TProtocol oprot) throws TException;
}
private Iface iface_;
protected final HashMap<String,ProcessFunction> processMap_ = new HashMap<String,ProcessFunction>();
public boolean process(TProtocol iprot, TProtocol oprot) throws TException
{