public interface SystemStreamPartitionGrouper
| Modifier and Type | Method and Description | 
|---|---|
| java.util.Map<TaskName,java.util.Set<SystemStreamPartition>> | group(java.util.Set<SystemStreamPartition> systemStreamPartitions)Groups the input systemStreamPartitions into the logical taskNames. | 
java.util.Map<TaskName,java.util.Set<SystemStreamPartition>> group(java.util.Set<SystemStreamPartition> systemStreamPartitions)
systemStreamPartitions - the input system stream partitions.TaskName to SystemStreamPartition assignments.