question: public void removeIndexKeyspace ( final String index ) throws IOException { try { QueryProcessor . process ( String . format ( "DROP KEYSPACE \"%s\";" , index ) , ConsistencyLevel . LOCAL_ONE ) ; } catch ( Throwable e ) { throw new IOException ( e . getMessage ( ) , e ) ; } }
target:  Don't use QueryProcessor.executeInternal, we need to propagate this on all nodes.