헥터/카산드라와 카운터를 설정하는 방법은 무엇입니까?

Question

나는 카산드라에게 hector가있는 카운터를 사용해야합니다. 카운터 1이 구성되지 않은 때문에, 그는 말한다 insertCounter 라인에

Mutator<String> m = createMutator(keyspace, se); 
    MutationResult mr = m.insertCounter(// exception here. 
    "k", "Counter1", createCounterColumn("name", 5)); 
    assertTrue("Execution time on single counter insert should be > 0", mr.getExecutionTimeMicro() > 0); 
    assertTrue("Should have operated on a host", mr.getHostUsed() != null); 
    CounterQuery<String, String> counter = new ThriftCounterColumnQuery<String,String>(keyspace, se, se); 
    counter.setColumnFamily("Counter1").setKey("k").setName("name"); 
    assertEquals(new Long(5), counter.execute().get().getValue()); 

그러나 나는이 예외를 얻을 :

me.prettyprint.hector.api.exceptions.HInvalidRequestException: InvalidRequestException(why:unconfigured columnfamily Counter1) 
    at me.prettyprint.cassandra.service.ExceptionsTranslatorImpl.translate(ExceptionsTranslatorImpl.java:45) ~[hector-core-1.0-5.jar:na] 
    at me.prettyprint.cassandra.connection.HConnectionManager.operateWithFailover(HConnectionManager.java:264) ~[hector-core-1.0-5.jar:na] 
    at me.prettyprint.cassandra.model.ExecutingKeyspace.doExecuteOperation(ExecutingKeyspace.java:97) ~[hector-core-1.0-5.jar:na] 
    at me.prettyprint.cassandra.model.MutatorImpl.execute(MutatorImpl.java:243) ~[hector-core-1.0-5.jar:na] 
    at me.prettyprint.cassandra.model.MutatorImpl.insertCounter(MutatorImpl.java:285) ~[hector-core-1.0-5.jar:na] 

OK,하지만 테스트 케이스가 '아무튼 나는 헥터에서 /이 this test case from test code 붙여 복사 카운터 1을 구성 하시겠습니까? 어떻게 구성합니까?

감사합니다.

Answer 1

Cassandra 서버에 컬럼 패밀리를 생성합니다. 일반적인 방법 중 하나는 cqlsh 도구를 사용하는 것입니다. 헥터에서

cqlsh 

USE Keyspace1; 
CREATE COLUMNFAMILY counter1 (example text PRIMARY KEY) 
    WITH comparator=text and default_validation=counter; 

, 당신은이 같은 ColumnFamilyDefinition 그 수업 뭔가 사용할 수 있습니다

ColumnFamilyDefinition cfDef = HFactory.createColumnFamilyDefinition(KEYSPACE, "counter1"); 
    cfDef.setKeyValidationClass(ComparatorType.UTF8TYPE.getClassName()); 
    cfDef.setComparatorType(ComparatorType.UTF8TYPE); 
    cfDef.setDefaultValidationClass(ComparatorType.COUNTERTYPE.getClassName()); 
    cfDef.setColumnType(ColumnType.STANDARD); 
    List<ColumnFamilyDefinition> columnFamilies = new ArrayList<ColumnFamilyDefinition>(); 
    columnFamilies.add(cfDef); 
    KeyspaceDefinition ksdef = HFactory.createKeyspaceDefinition(KEYSPACE, "org.apache.cassandra.locator.SimpleStrategy", 1, 
      columnFamilies); 
    cluster.addKeyspace(ksdef);