void drainQueue() throws SQLException {
    FetchResult result;
    while ((result = resultQueue.poll()) != null) {
      if (result.ex != null) {
        throw new SQLException(result.ex);
      }
    }
  }
Set the specified schema to the resultset
@param colNames
@param colTypes
jdbc/src/java/org/apache/hive/jdbc/HiveQueryResultSet.java