code: 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();
      }
docs: Connect to Cassandra host.