private ResourceManagerFactory getContainerProcessManagerFactory(final ClusterManagerConfig clusterManagerConfig) {
    final String containerManagerFactoryClass = clusterManagerConfig.getContainerManagerClass();
    final ResourceManagerFactory factory;

    try {
      factory = ReflectionUtil.getObj(containerManagerFactoryClass, ResourceManagerFactory.class);
    } catch (Exception e) {
      LOG.error("Error creating the cluster resource manager.", e);
      throw new SamzaException(e);
    }
    return factory;
  }
Returns an instantiated {@link ResourceManagerFactory} from a {@link ClusterManagerConfig}. The
{@link ResourceManagerFactory} is used to return an implementation of a {@link ClusterResourceManager}

@param clusterManagerConfig, the cluster manager config to parse.
samza-core/src/main/java/org/apache/samza/clustermanager/ContainerProcessManager.java