You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2016/04/05 22:56:41 UTC
[7/8] incubator-beam git commit: fixup! Move GroupByKey expansion
into DirectPipelineRunner
fixup! Move GroupByKey expansion into DirectPipelineRunner
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/52cd18a3
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/52cd18a3
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/52cd18a3
Branch: refs/heads/master
Commit: 52cd18a34b51acbda3895b8d31cd9f73a80634cc
Parents: 1bbaf1a
Author: Kenneth Knowles <kl...@google.com>
Authored: Mon Mar 28 14:42:57 2016 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Mon Mar 28 14:42:57 2016 -0700
----------------------------------------------------------------------
.../apache/beam/runners/spark/translation/TransformTranslator.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/52cd18a3/runners/spark/src/main/java/org/apache/beam/runners/spark/translation/TransformTranslator.java
----------------------------------------------------------------------
diff --git a/runners/spark/src/main/java/org/apache/beam/runners/spark/translation/TransformTranslator.java b/runners/spark/src/main/java/org/apache/beam/runners/spark/translation/TransformTranslator.java
index b8fcc75..59bd7c7 100644
--- a/runners/spark/src/main/java/org/apache/beam/runners/spark/translation/TransformTranslator.java
+++ b/runners/spark/src/main/java/org/apache/beam/runners/spark/translation/TransformTranslator.java
@@ -47,7 +47,7 @@ import com.google.cloud.dataflow.sdk.transforms.windowing.GlobalWindows;
import com.google.cloud.dataflow.sdk.transforms.windowing.Window;
import com.google.cloud.dataflow.sdk.transforms.windowing.WindowFn;
import com.google.cloud.dataflow.sdk.util.AssignWindowsDoFn;
-import com.google.cloud.dataflow.sdk.util.GroupByKeyOnly;
+import com.google.cloud.dataflow.sdk.util.GroupByKeyViaGroupByKeyOnly.GroupByKeyOnly;
import com.google.cloud.dataflow.sdk.util.WindowedValue;
import com.google.cloud.dataflow.sdk.values.KV;
import com.google.cloud.dataflow.sdk.values.PCollection;