beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lc...@apache.org
Subject [3/3] beam git commit: [BEAM-1871] Move GCP specific serialization CloudObject and supporting translation code to Dataflow runner module
Date Wed, 03 May 2017 19:47:38 GMT
[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 <lcwik@google.com>
Authored: Wed May 3 12:47:25 2017 -0700
Committer: Luke Cwik <lcwik@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(-)
----------------------------------------------------------------------



Mime
View raw message