private static Cassandra.Client createThriftClient(String host, int port) throws TTransportException
{
TSocket socket = new TSocket(host, port);
TTransport trans = new TFramedTransport(socket);
trans.open();
TProtocol protocol = new org.apache.thrift.protocol.TBinaryProtocol(trans);
return new Cassandra.Client(protocol);
}
}