private int getMaxNumTasks() {
    // Do grouping to fetch TaskName to SSP mapping
    Set<SystemStreamPartition> allSystemStreamPartitions = getInputStreamPartitions();
    SystemStreamPartitionGrouper grouper = getSystemStreamPartitionGrouper();
    Map<TaskName, Set<SystemStreamPartition>> groups = grouper.group(allSystemStreamPartitions);
    LOG.info("SystemStreamPartitionGrouper " + grouper.toString() + " has grouped the SystemStreamPartitions into " + Integer.toString(groups.size()) +
        " tasks with the following taskNames: {}", groups.keySet());
    return groups.size();
  }
Gets a SystemStreamPartitionGrouper object from the configuration.
samza-azure/src/main/java/org/apache/samza/coordinator/AzureJobCoordinator.java