Olá.
Estou começando os estudos com o Cassandra 0.8.2 e estou rodando no linux ubuntu 8…0.2. Conseguir faze-lo rodar tranquilamente.
Quando crio um projeto estou adicionando todas as libs dentro da pasta do próprio cassandra. Conseguir achar alguns exemplos legais na internet.
No entanto até o momento nenhum até agora funcionou.
Normalmente está dando a seguinte execeção durante a inserção de uma tabel.a
Exception in thread “main” org.apache.thrift.transport.TTransportException: Cannot write to null outputStream
at org.apache.thrift.transport.TIOStreamTransport.write(TIOStreamTransport.java:142)
at org.apache.thrift.transport.TFramedTransport.flush(TFramedTransport.java:156)
at org.apache.cassandra.thrift.Cassandra$Client.send_set_keyspace(Cassandra.java:466)
at org.apache.cassandra.thrift.Cassandra$Client.set_keyspace(Cassandra.java:455)
at cassandrafirtexample.CassandraFirtExample.main(CassandraFirtExample.java:79)
Java Result: 1
Se alguém puder me ajudar ou enviar um passo a passo de inserção de dados no cassandra ficaria grato, abaixo segue meu código.
public static void main(String[] args) throws Exception {
TTransport transport = new TFramedTransport(new TSocket("localhost", 9160));
TProtocol protocol = new TBinaryProtocol(transport);
Cassandra.Client client = new Cassandra.Client(protocol);
// client.set_keyspace("mindplex");
ColumnParent parent = new ColumnParent("User");
ByteBuffer rowid = ByteBuffer.wrap("100".getBytes());
Column column = new Column();
column.setName("description".getBytes());
column.setValue("some value here...".getBytes());
column.setTimestamp(System.currentTimeMillis());
client.insert(rowid, parent, column, ConsistencyLevel.ONE);
transport.flush();
transport.close();
}
}
