[BEAM-1871] Move GCP specific serialization CloudObject and supporting translation code to Dataflow runner module
This closes #2862 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/aafa1bba Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/aafa1bba Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/aafa1bba Branch: refs/heads/DSL_SQL Commit: aafa1bba984ac9744ef3f21c60a402aee3cec293 Parents: 320f9af a5627b1 Author: Luke Cwik <lc...@google.com> Authored: Wed May 3 12:47:25 2017 -0700 Committer: Luke Cwik <lc...@google.com> Committed: Wed May 3 12:47:25 2017 -0700 ---------------------------------------------------------------------- runners/google-cloud-dataflow-java/pom.xml | 2 +- .../dataflow/DataflowPipelineTranslator.java | 18 +- .../beam/runners/dataflow/DataflowRunner.java | 2 +- .../beam/runners/dataflow/ReadTranslator.java | 8 +- .../dataflow/internal/CustomSources.java | 6 +- .../util/AvroCoderCloudObjectTranslator.java | 2 - .../beam/runners/dataflow/util/CloudObject.java | 1 - .../runners/dataflow/util/CloudObjectKinds.java | 2 - .../dataflow/util/CloudObjectTranslator.java | 2 - .../dataflow/util/CloudObjectTranslators.java | 23 +- .../runners/dataflow/util/CloudObjects.java | 1 - .../CoderCloudObjectTranslatorRegistrar.java | 1 - .../runners/dataflow/util/PropertyNames.java | 112 ++++++ .../SerializableCoderCloudObjectTranslator.java | 2 - .../beam/runners/dataflow/util/Serializer.java | 262 ------------- .../beam/runners/dataflow/util/Structs.java | 372 +++++++++++++++++++ .../DataflowPipelineTranslatorTest.java | 10 +- .../runners/dataflow/util/CloudObjectsTest.java | 1 - .../beam/runners/dataflow/util/StructsTest.java | 206 ++++++++++ .../apache/beam/sdk/coders/CollectionCoder.java | 13 - .../apache/beam/sdk/coders/IterableCoder.java | 13 - .../org/apache/beam/sdk/coders/KvCoder.java | 13 - .../beam/sdk/coders/LengthPrefixCoder.java | 13 - .../org/apache/beam/sdk/coders/ListCoder.java | 13 - .../org/apache/beam/sdk/coders/SetCoder.java | 16 - .../apache/beam/sdk/util/CloudKnownType.java | 143 ------- .../org/apache/beam/sdk/util/CloudObject.java | 187 ---------- .../org/apache/beam/sdk/util/CoderUtils.java | 117 ------ .../org/apache/beam/sdk/util/PropertyNames.java | 112 ------ .../org/apache/beam/sdk/util/Serializer.java | 147 -------- .../java/org/apache/beam/sdk/util/Structs.java | 371 ------------------ .../java/org/apache/beam/sdk/util/Values.java | 88 ----- .../org/apache/beam/sdk/util/WindowedValue.java | 22 -- .../org/apache/beam/sdk/values/TupleTag.java | 22 -- .../apache/beam/sdk/util/SerializerTest.java | 162 -------- .../org/apache/beam/sdk/util/StructsTest.java | 206 ---------- 36 files changed, 729 insertions(+), 1962 deletions(-) ----------------------------------------------------------------------
