private static void startLocalCassandra ( String cassandraYamlPath ) throws IOException { System . setProperty ( "cassandra.config" , "file:" + cassandraYamlPath ) ; final CassandraDaemon cassandra = new CassandraDaemon ( ) ; cassandra . init ( null ) ; Futures . getUnchecked ( service . submit ( new Callable < Object > ( ) { @ Override public Object call ( ) throws Exception { cassandra . start ( ) ; return null ; } } ) ) ; }
Start an in - memory Cassandra .