@VisibleForTesting
  static CoordinatorStreamStore buildCoordinatorStreamStore(Config config, MetricsRegistryMap metricsRegistryMap) {
    return new CoordinatorStreamStore(config, metricsRegistryMap);
  }
This method launches a Samza container in a managed cluster, e.g. Yarn.
samza-core/src/main/java/org/apache/samza/runtime/ContainerLaunchUtil.java