2012-02-06 10 views
11

Uczę się Apache Cassandra w wersji 0.7.6 z java i Hector, i próbowałem stworzyć klaster, keyspace i wstawić kolumnę w tym keyspace utworzony.wstawić wiersz na keyspace w Apache Cassandra + Hector + Java

Szukając przykładów, zrozumiałem, że keyspace jest odpowiednikiem bazy danych w bazach Sql, a Column Familys jest równoważny z tabelami. Wiedząc o tym, próbowałem stworzyć swoją prostą przykładową strukturę.

Cluster tutorialCluster = HFactory.getOrCreateCluster("TutorialCluster", 
      "127.0.0.1:9160"); 
ConfigurableConsistencyLevel ccl = new ConfigurableConsistencyLevel(); 

ccl.setDefaultReadConsistencyLevel(HConsistencyLevel.ONE); 

Keyspace tutorialKeyspace = HFactory.createKeyspace("Tutorial", tutorialCluster, 
      ccl); 
Mutator<String> mutator = HFactory.createMutator(tutorialKeyspace, 
      stringSerializer); 

mutator.addInsertion("CA Burlingame", "StateCity", HFactory.createColumn(650L, "37.57x122.34", longSerializer, stringSerializer)); 

MutationResult mr = mutator.execute(); 

Ale kiedy próbowałem uruchomić to, z Kasandra rozpoczęła, ale zwraca wyjątek.

Exception in thread "main" me.prettyprint.hector.api.exceptions.HInvalidRequestException: InvalidRequestException(why:Keyspace Tutorial does not exist) 
at me.prettyprint.cassandra.connection.HThriftClient.getCassandra(HThriftClient.java:70) 
at me.prettyprint.cassandra.connection.HConnectionManager.operateWithFailover(HConnectionManager.java:226) 

Ale już utworzyłem "Tutorial" keyspace i użyłem go w mutatorze.

Ktoś może mi powiedzieć, co jest możliwe?

góry dzięki

Odpowiedz

Powiązane problemy