private Predicate<StatisticEvent> getInsideProcessingThresholdPredicate() {
        return Optional
                .ofNullable(configProvider.get().getMaxProcessingAge())
                .map(TimeUtils::durationToThreshold)
                .map(threshold ->
                        (Predicate<StatisticEvent>) statisticEvent ->
                                statisticEvent.getTimeMs() > threshold.toEpochMilli())
                .orElse(statisticEvent -> true);
    }
@return A predicate that will test if an event is within the processing age threshold, or if there
is no configured max age then process all events
stroom-statistics/stroom-statistics-impl-sql/src/main/java/stroom/statistics/impl/sql/SQLStatisticEventStore.java