public void emitReplayedTuples(PreparedStatement ps){
  ResultSet rs=null;
  try (PreparedStatement pStat=ps){
    pStat.setFetchSize(getFetchSize());
    rs=pStat.executeQuery();
    if (rs == null || rs.isClosed()) {
      return;
    }
    while (rs.next()) {
      emitTuple(getTuple(rs));
      lastEmittedRow++;
    }
  }
 catch (  SQLException ex) {
    throw new RuntimeException(ex);
  }
}

public void emitReplayedTuples ( PreparedStatement ps ) { ResultSet rs = null ; try ( PreparedStatement pStat = ps ) { pStat . setFetchSize ( getFetchSize ( ) ) ; rs = pStat . executeQuery ( ) ; if ( rs == null || rs . isClosed ( ) ) { return ; } while ( rs . next ( ) ) { emitTuple ( getTuple ( rs ) ) ; lastEmittedRow ++ ; } } catch ( SQLException ex ) { throw new RuntimeException ( ex ) ; } }
replays the tuples in sync mode for replayed windows
