code: 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)");
      }
docs: 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.
  @param statement Statement to be executed
  @throws SchemaAgreementException exception