private KsDef onCreateKeyspace ( ) throws Exception { try { createdKeyspaces . add ( databaseName ) ; createKeyspace ( ) ; } catch ( InvalidRequestException irex ) { // Ignore and add a log.debug // keyspace already exists. // remove from list if already created. createdKeyspaces . remove ( databaseName ) ; } cassandra_client . set_keyspace ( databaseName ) ; return cassandra_client . describe_keyspace ( databaseName ) ; }
On create keyspace .