commonlib/src/main/java/com/streamsets/pipeline/lib/io/LiveDirectoryScanner.java
public long getPendingFiles(LiveFile current) throws IOException{
    //Current will not be acceptable for roll files (if active file is without a counter/date pattern)
    //and will be later renamed to a file with counter/date suffix, if that is the case we should
    //return 0 as number of pending files
    if (current == null || rollMode.isCurrentAcceptable(current.getPath().getFileName().toString())) {
      return findToBeProcessedMatchingFiles(current!=null? current.refresh() : null).size();
    }
    return 0;
  }
public long getPendingFiles(LiveFile current) throws IOException{
    //Current will not be acceptable for roll files (if active file is without a counter/date pattern)
    //and will be later renamed to a file with counter/date suffix, if that is the case we should
    //return 0 as number of pending files
    if (current == null || rollMode.isCurrentAcceptable(current.getPath().getFileName().toString())) {
      return findToBeProcessedMatchingFiles(current!=null? current.refresh() : null).size();
    }
    return 0;
  }
Scans the directory for number of files yet to be processed.

@param current the last 'rolled' file processed. Use <code>null</code> to look for the first one.
@return the number of files yet to be processed.
@throws IOException thrown if the directory could not be scanned.