public void connect ( String secured ) { buildCluster ( secured ) ; this . cassandraqueryUtils = new CassandraQueryUtils ( ) ; this . metadata = this . cluster . getMetadata ( ) ; LOGGER . debug ( "Connected to cluster (" + host + "): " + metadata . getClusterName ( ) + "\n" ) ; this . session = this . cluster . connect ( ) ; }
Connect to Cassandra host .