// Set the consistency level on the query
query.setConsistencyLevel(clLevel);
// Set the retry policy on the query
if (retry instanceof JavaDriverBasedRetryPolicy) {
JavaDriverBasedRetryPolicy jdRetryPolicy = (JavaDriverBasedRetryPolicy) retry;
query.setRetryPolicy(jdRetryPolicy.getJDRetryPolicy());
}
ResultSet resultSet = session.execute(query);
R result = parseResultSet(resultSet);
OperationResult<R> opResult = new CqlOperationResultImpl<R>(resultSet, result);