public void seek()

in kinesis-taxi-stream-producer/src/main/java/com/amazonaws/flink/refarch/utils/TaxiEventReader.java [57:70]

• 11 lines of code
• 5 McCabe index (conditional complexity)

  public void seek(long timestamp, int skipNumLines) {
    while (next.timestamp < timestamp && hasNext) {
      //skip skipNumLines before parsing next event
      try {
        for (int i = 0; i < skipNumLines; i++) {
          objectStream.readLine();
        }
      } catch (IOException | NullPointerException e) {
        // if the next line cannot be read, that's fine, the next S3 object will be opened and read by next()
      }

      next();
    }
  }