code: public static <E extends Exception, E2 extends Exception> void parse(final PreparedStatement stmt, final long offset, final long count,
              final int processThreadNum, final int queueSize, final Try.Consumer<Object[], E> rowParser, final Try.Runnable<E2> onComplete)
              throws UncheckedSQLException, E, E2 {
          ResultSet rs = null;
  
          try {
              rs = stmt.executeQuery();
  
              parse(rs, offset, count, processThreadNum, queueSize, rowParser, onComplete);
          } catch (SQLException e) {
              throw new UncheckedSQLException(e);
          } finally {
              closeQuietly(rs);
          }
      }
docs: Parse the ResultSet obtained by executing query with the specified PreparedStatement.
  
  @param stmt
  @param offset
  @param count
  @param processThreadNum new threads started to parse/process the lines/records
  @param queueSize size of queue to save the processing records/lines loaded from source data. Default size is 1024.
  @param rowParser
  @param onComplete
  @throws UncheckedSQLException