code: public void reconnect() {
          metadata = cluster.getMetadata();
          LOGGER.debug("Connected to cluster (" + host + "): "
                  + metadata.getClusterName() + "\n");
          this.session = this.cluster.connect();
      }
docs: Reconnect to Cassandra host.