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 <k...@google.com> Authored: Mon Mar 28 14:42:57 2016 -0700 Committer: Kenneth Knowles <k...@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;