@Override
    public void funnel(Config from, PrimitiveSink into) {
      SortedMap<String, String> map = new TreeMap<>();

      ALLOWED_PREFIXES.forEach(prefix -> map.putAll(from.subset(prefix, false)));
      LOG.info("Using the config {} to generate hash", map);
      map.forEach((key, value) -> {
        into.putUnencodedChars(key);
        into.putUnencodedChars(value);
      });
    }
A helper class to generate hash for the {@link Config} based on with a subset of configuration.
The subset of configuration used are configurations that prefix match the allowed prefixes.
samza-core/src/main/java/org/apache/samza/job/metadata/JobCoordinatorMetadataManager.java