return jobsByHost.entrySet()
    .stream()
    .collect(Collectors.toMap(Map.Entry::getKey,
        e -> e.getValue()
              .stream()
              .map(finalMetricByJobKey::get)
              .map(jobInfoLookup::get)
              .filter(e -> e != null)
              .map(e -> new ReplicatedMetricEntry(FuzzyKey...))
              .collect(Collectors.toList())));