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 ) ; } }
Parse the ResultSet obtained by executing query with the specified PreparedStatement .