Use Guava directly instead of via Google API Client lib
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/080eeaa7 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/080eeaa7 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/080eeaa7 Branch: refs/heads/master Commit: 080eeaa7c771a3d9a4557852a793780abda6bbef Parents: 6751e49 Author: Kenneth Knowles <k...@google.com> Authored: Mon Mar 28 09:14:01 2016 -0700 Committer: Kenneth Knowles <k...@google.com> Committed: Mon Mar 28 09:14:01 2016 -0700 ---------------------------------------------------------------------- .../beam/runners/spark/translation/TransformTranslator.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/080eeaa7/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 7abf1bf..b8fcc75 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 @@ -30,8 +30,6 @@ import java.util.Collections; import java.util.List; import java.util.Map; -import com.google.api.client.util.Lists; -import com.google.api.client.util.Maps; import com.google.cloud.dataflow.sdk.coders.CannotProvideCoderException; import com.google.cloud.dataflow.sdk.coders.Coder; import com.google.cloud.dataflow.sdk.coders.KvCoder; @@ -58,6 +56,8 @@ import com.google.cloud.dataflow.sdk.values.PCollectionTuple; import com.google.cloud.dataflow.sdk.values.PCollectionView; import com.google.cloud.dataflow.sdk.values.TupleTag; import com.google.common.collect.ImmutableMap; +import com.google.common.collect.Lists; +import com.google.common.collect.Maps; import org.apache.avro.mapred.AvroKey; import org.apache.avro.mapreduce.AvroJob;
