@ Override public String getVersion ( ) throws ConnectionException { return connectionPool . executeWithFailover ( new AbstractOperationImpl < String > ( tracerFactory . newTracer ( CassandraOperationType . GET_VERSION ) ) { @ Override public String internalExecute ( Client client , ConnectionContext state ) throws Exception { return client . describe_version ( ) ; } } , config . getRetryPolicy ( ) . duplicate ( ) ) . getResult ( ) ; }
Get the version from the cluster