protected void executeWithSchemaAgreement ( Statement statement ) throws SchemaAgreementException { ResultSet result = this . session . execute ( statement ) ; if ( checkSchemaAgreement ( result ) ) { return ; } if ( checkClusterSchemaAgreement ( ) ) { return ; } throw new SchemaAgreementException ( "Failed to propagate schema update to all nodes (schema agreement error)" ) ; }
Execute provided statement and checks if the schema migration has been propagated to all nodes in the cluster . Use this method when executing schema migrations .