public Integer getRecordsReadPs() {
        if (stats.getRecordsRead() != null && durationMs != null && durationMs > 0) {
            return (int) ((double) stats.getRecordsRead().longValue() / durationMs * MS_IN_SEC);
        }
        return null;
    }
@return number of records read per second
stroom-processor/stroom-processor-impl/src/main/java/stroom/processor/impl/StreamTaskDerivedStats.java