code: @SuppressWarnings("unused")
    private List<Long> getValidationOutputFromHiveJdbc(List<String> queries) throws IOException {
      if (null == queries || queries.size() == 0) {
        log.warn("No queries specified to be executed");
        return Collections.emptyList();
      }
      Statement statement = null;
      List<Long> rowCounts = Lists.newArrayList();
      Closer closer = Closer.create();
  
      try {
        HiveJdbcConnector hiveJdbcConnector = HiveJdbcConnector.newConnectorWithProps(props);
        statement = hiveJdbcConnector.getConnection().createStatement();
  
        for (String query : queries) {
          log.info("Executing query: " + query);
          boolean result = statement.execute(query);
          if (result) {
            ResultSet resultSet = statement.getResultSet();
            if (resultSet.next()) {
              rowCounts.add(resultSet.getLong(1));
            }
          } else {
            log.warn("Query output for: " + query + " : " + result);
          }
        }
  
      } catch (SQLException e) {
        throw new RuntimeException(e);
      } finally {
        try {
          closer.close();
        } catch (Exception e) {
          log.warn("Could not close HiveJdbcConnector", e);
        }
        if (null != statement) {
          try {
            statement.close();
          } catch (SQLException e) {
            log.warn("Could not close Hive statement", e);
          }
        }
      }
  
      return rowCounts;
    }
docs: *
  Execute Hive queries using {@link HiveJdbcConnector} and validate results.
  @param queries Queries to execute.