关于cassandra0.7.5的操作,该怎么解决

关于cassandra0.7.5的操作
 


import java.nio.ByteBuffer;

import org.apache.cassandra.thrift.Cassandra;
import org.apache.cassandra.thrift.Column;   
import org.apache.cassandra.thrift.ColumnPath;   
import org.apache.cassandra.thrift.ConsistencyLevel;   
import org.apache.cassandra.thrift.InvalidRequestException;   
import org.apache.cassandra.thrift.NotFoundException;   
import org.apache.cassandra.thrift.TimedOutException;   
import org.apache.cassandra.thrift.UnavailableException;   
import org.apache.thrift.TException;   
import org.apache.thrift.protocol.TBinaryProtocol;   
import org.apache.thrift.transport.TSocket;   
import org.apache.thrift.transport.TTransport;   
import org.apache.thrift.transport.TTransportException;   
  
  
 public class SampleOne {     
     static Cassandra.Client cassandraClient;     
     static TTransport socket;   
      
      
     private static void init() throws TTransportException {     
//         String server = "192.168.1.129";     
       String server = "localhost";   
         int port = 9160;     
      
         /* 首先指定cassandra server的地址 */     
         socket = new TSocket(server, port);     
         System.out.println(" connected to " + server + ":" + port + ".");     
      
      
         /* 指定通信协议为二进制流协议 */     
         TBinaryProtocol binaryProtocol = new TBinaryProtocol(socket, false, false);     
         cassandraClient = new Cassandra.Client(binaryProtocol);     
      
      
         /* 建立通信连接 */     
         socket.open();     
     }     
      
      
     public static void main(String[] args) throws Exception {     
         /* 初始化连接 */     
         init();     
      
      
         /* 选择需要操作的Keyspaces， 可以理解成数据库的表 */