| commit | 4584d5d8aadf12d2f2c80d5c73cc97fde7910cc8 | [log] [tgz] |
|---|---|---|
| author | smptx <58271370+smptx@users.noreply.github.com> | Tue Jan 11 05:47:24 2022 -0800 |
| committer | GitHub <noreply@github.com> | Tue Jan 11 05:47:24 2022 -0800 |
| tree | c4c4ccc2cd6f650e740e788a93b188e0a532b413 | |
| parent | b76a7af055b7038cb75fd7d6ff0a3e42287a377e [diff] |
SAMZA-2680 Remove wildcard import from SystemStreamPartitionGrouper. (#1574)
diff --git a/samza-api/src/main/java/org/apache/samza/container/grouper/stream/SystemStreamPartitionGrouper.java b/samza-api/src/main/java/org/apache/samza/container/grouper/stream/SystemStreamPartitionGrouper.java index 6076076..6110689 100644 --- a/samza-api/src/main/java/org/apache/samza/container/grouper/stream/SystemStreamPartitionGrouper.java +++ b/samza-api/src/main/java/org/apache/samza/container/grouper/stream/SystemStreamPartitionGrouper.java
@@ -18,11 +18,12 @@ */ package org.apache.samza.container.grouper.stream; -import java.util.*; - import org.apache.samza.container.TaskName; import org.apache.samza.system.SystemStreamPartition; +import java.util.Map; +import java.util.Set; + /** * Group a set of SystemStreamPartitions into logical taskNames that share a common characteristic, defined * by the implementation. Each taskName has a key that uniquely describes what sets may be in it, but does