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.