This is an automated email from the ASF dual-hosted git repository. jkff pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
commit bbabb4202cdbe234ab7be9a1cda57f0e8e226357 Merge: 5bb482f 58502e0 Author: Eugene Kirpichov <[email protected]> AuthorDate: Wed Apr 25 16:08:06 2018 -0700 Merge pull request #4672: Moves standard URNs into .proto files Moves standard URNs into .proto files .gitignore | 1 - .../beam/model/fnexecution/v1/standard_coders.yaml | 56 ++--- .../pipeline/src/main/proto/beam_runner_api.proto | 141 ++++++++++++ .../src/main/proto/standard_window_fns.proto | 25 ++- .../resources/org/apache/beam/model/common_urns.md | 134 ------------ pom.xml | 1 - runners/core-construction-java/build.gradle | 2 + runners/core-construction-java/pom.xml | 13 ++ .../beam/runners/core/construction/BeamUrns.java | 29 +++ .../core/construction/ModelCoderRegistrar.java | 4 + .../runners/core/construction/ModelCoders.java | 19 +- .../core/construction/PTransformTranslation.java | 41 ++-- .../beam/runners/core/construction/UrnUtils.java | 63 ------ .../construction/WindowingStrategyTranslation.java | 82 +++---- .../core/construction}/CommonCoderTest.java | 241 +++++++++++---------- .../runners/core/construction/UrnUtilsTest.java | 59 ----- runners/java-fn-execution/build.gradle | 1 + .../control/ProcessBundleDescriptors.java | 5 +- .../graph/LengthPrefixUnknownCoders.java | 18 +- sdks/java/core/build.gradle | 1 + .../beam/fn/harness/WindowMappingFnRunner.java | 6 +- sdks/python/apache_beam/coders/coders.py | 18 +- .../apache_beam/coders/standard_coders_test.py | 28 +-- sdks/python/apache_beam/io/iobase.py | 4 +- sdks/python/apache_beam/pipeline.py | 2 +- sdks/python/apache_beam/portability/common_urns.py | 62 ++++++ sdks/python/apache_beam/pvalue.py | 10 +- .../runners/dataflow/dataflow_runner.py | 12 +- .../runners/portability/fn_api_runner.py | 50 ++--- .../apache_beam/runners/worker/bundle_processor.py | 24 +- .../apache_beam/testing/data/standard_coders.yaml | 56 ++--- sdks/python/apache_beam/transforms/core.py | 25 ++- sdks/python/apache_beam/transforms/window.py | 16 +- sdks/python/setup.py | 31 --- 34 files changed, 632 insertions(+), 648 deletions(-) -- To stop receiving notification emails like this one, please contact [email protected].
