private static List<SystemStreamPartition> getSystemStreamPartitions(JobModel jobModel) {
    List<SystemStreamPartition> ssps = new ArrayList<>();
    jobModel.getContainers().forEach((containerName, containerModel) -> {
      containerModel.getTasks().forEach((taskName, taskModel) -> ssps.addAll(taskModel.getSystemStreamPartitions()));
    });
    return ssps;
  }
Computes the task to partition assignment of the {@param JobModel}.
@param jobModel the jobModel to compute task to partition assignment for.
@return the computed task to partition assignments of the {@param JobModel}.
samza-test/src/test/java/org/apache/samza/test/processor/TestZkLocalApplicationRunner.java