You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by re...@apache.org on 2021/04/24 15:17:32 UTC

[beam] branch master updated (2aab1b0 -> 805f818)

This is an automated email from the ASF dual-hosted git repository.

reuvenlax pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from 2aab1b0  [BEAM-7372] cleanup py2 codepaths in apache_beam/runners/direct, job, portability and test #14565
     add 805f818  Merge pull request #14591: [BEAM-10277][BEAM-12198] Dataflow update support for schemas

No new revisions were added by this update.

Summary of changes:
 ...DefaultCoderCloudObjectTranslatorRegistrar.java |   1 +
 .../util/RowCoderCloudObjectTranslator.java        |  72 +++++++++++
 .../util/SchemaCoderCloudObjectTranslator.java     |  22 ++--
 .../runners/dataflow/util/CloudObjectsTest.java    |   4 +-
 .../apache/beam/sdk/coders/RowCoderGenerator.java  | 104 ++++++++++++----
 .../java/org/apache/beam/sdk/schemas/Schema.java   |   4 +
 .../apache/beam/sdk/schemas/SchemaTranslation.java |  14 ++-
 .../org/apache/beam/sdk/coders/RowCoderTest.java   | 134 +++++++++++++++++++++
 8 files changed, 319 insertions(+), 36 deletions(-)
 create mode 100644 runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/RowCoderCloudObjectTranslator.java