@Override public void createIndexKeyspace(final String ksname,final int replicationFactor) throws IOException {
  try {
    Keyspace ks=Keyspace.open(ksname);
    if (ks != null && !(ks.getReplicationStrategy() instanceof NetworkTopologyStrategy)) {
      throw new IOException("Cannot create index, underlying keyspace requires the NetworkTopologyStrategy.");
    }
  }
 catch (  AssertionError e) {
  }
  try {
    QueryProcessor.process(String.format("CREATE KEYSPACE IF NOT EXISTS \"%s\" WITH replication = {'class':'NetworkTopologyStrategy', '%s':'%d' };",ksname,DatabaseDescriptor.getLocalDataCenter(),replicationFactor),ConsistencyLevel.LOCAL_ONE);
  }
 catch (  Throwable e) {
    throw new IOException(e.getMessage(),e);
  }
}

@ Override public void createIndexKeyspace ( final String ksname , final int replicationFactor ) throws IOException { try { Keyspace ks = Keyspace . open ( ksname ) ; if ( ks != null && ! ( ks . getReplicationStrategy ( ) instanceof NetworkTopologyStrategy ) ) { throw new IOException ( "Cannot create index, underlying keyspace requires the NetworkTopologyStrategy." ) ; } } catch ( AssertionError e ) { } try { QueryProcessor . process ( String . format ( "CREATE KEYSPACE IF NOT EXISTS \"%s\" WITH replication = {'class':'NetworkTopologyStrategy', '%s':'%d' };" , ksname , DatabaseDescriptor . getLocalDataCenter ( ) , replicationFactor ) , ConsistencyLevel . LOCAL_ONE ) ; } catch ( Throwable e ) { throw new IOException ( e . getMessage ( ) , e ) ; } }
don ' t use queryprocessor . executeinternal , we need to propagate this on all nodes .
