We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e106213 commit c2fd294Copy full SHA for c2fd294
1 file changed
runners/spark/src/main/java/org/apache/beam/runners/spark/translation/streaming/ParDoStateUpdateFn.java
@@ -19,6 +19,7 @@
19
20
import java.io.Serializable;
21
import java.util.Collection;
22
+import java.util.Collections;
23
import java.util.Iterator;
24
import java.util.List;
25
import java.util.Map;
@@ -62,7 +63,6 @@
62
63
import org.checkerframework.checker.nullness.qual.Nullable;
64
import org.slf4j.Logger;
65
import org.slf4j.LoggerFactory;
-import java.util.Collections;
66
import scala.Option;
67
import scala.Tuple2;
68
import scala.runtime.AbstractFunction3;
0 commit comments