import org.apache.thrift.TException;
import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.protocol.TProtocol;
import org.apache.thrift.transport.TSocket;
import org.apache.thrift.transport.TTransport;
public class CassandraHelloWorld {
public static void main(String[] args) throws UnsupportedEncodingException, InvalidRequestException, UnavailableException, TimedOutException, TException, NotFoundException {
//Part One
TTransport trans = new TSocket("127.0.0.1", 9160);
TProtocol proto = new TBinaryProtocol(trans);
Cassandra.Client client = new Cassandra.Client(proto);
trans.open();
//Part Two
String keyspace = "Keyspace1";
String cf = "Standard2";
String key = "kylinsoong";
long timestamp = new Date().getTime();
ColumnPath path = new ColumnPath(cf);
path.setColumn("id".getBytes("UTF-8"));
client.insert(keyspace, key, path, "520".getBytes("UTF-8"), timestamp, ConsistencyLevel.ONE);
path.setColumn("action".getBytes("UTF-8"));
client.insert(keyspace, key, path, "Hello, World, Cassandra!".getBytes("UTF-8"), timestamp, ConsistencyLevel.ONE);
//Part Three
path.setColumn("id".getBytes("UTF-8"));
ColumnOrSuperColumn cc = client.get(keyspace, key, path, ConsistencyLevel.ONE);
Column c = cc.getColumn();
String value = new String(c.value, "UTF-8");
System.out.println(value);
path.setColumn("action".getBytes("UTF-8"));
ColumnOrSuperColumn cc2 = client.get(keyspace, key, path, ConsistencyLevel.ONE);
Column c2 = cc2.getColumn();
String value2 = new String(c2.value, "UTF-8");
System.out.println(value2);
