You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by bh...@apache.org on 2022/01/11 13:47:33 UTC
[samza] branch master updated: SAMZA-2680 Remove wildcard import from SystemStreamPartitionGrouper. (#1574)
This is an automated email from the ASF dual-hosted git repository.
bharathkk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/samza.git
The following commit(s) were added to refs/heads/master by this push:
new 4584d5d SAMZA-2680 Remove wildcard import from SystemStreamPartitionGrouper. (#1574)
4584d5d is described below
commit 4584d5d8aadf12d2f2c80d5c73cc97fde7910cc8
Author: smptx <58...@users.noreply.github.com>
AuthorDate: Tue Jan 11 05:47:24 2022 -0800
SAMZA-2680 Remove wildcard import from SystemStreamPartitionGrouper. (#1574)
---
.../samza/container/grouper/stream/SystemStreamPartitionGrouper.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
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