You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2017/05/03 19:47:38 UTC
[3/3] beam git commit: [BEAM-1871] Move GCP specific serialization
CloudObject and supporting translation code to Dataflow runner module
[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/master
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(-)
----------------------------------------------------------------------