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 2019/12/21 18:33:03 UTC
[beam] branch master updated (76a0fcf -> a90336b)

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 76a0fcf  Merge pull request #10434: [BEAM-8996] Improvements to the Flink runner page
     add a90336b  Merge pull request #10356: [BEAM-7274] Infer a Beam Schema from a protocol buffer class.

No new revisions were added by this update.

Summary of changes:
 model/pipeline/src/main/proto/schema.proto         |  52 +++
 .../core/construction/CoderTranslators.java        |   2 +-
 .../core/construction/SchemaTranslationTest.java   |   2 +-
 .../util/SchemaCoderCloudObjectTranslator.java     |   2 +-
 .../java/org/apache/beam/sdk/schemas/Schema.java   |   8 +-
 .../apache/beam/sdk/schemas/SchemaTranslation.java | 147 +++++++-
 .../beam/sdk/schemas/logicaltypes/OneOfType.java   |  42 ++-
 .../main/java/org/apache/beam/sdk/values/Row.java  |   8 +-
 .../sdk/schemas/logicaltypes/LogicalTypesTest.java |   8 +-
 .../protobuf/ProtoSchemaLogicalTypes.java          | 186 ++++++++++
 .../extensions/protobuf/ProtoSchemaTranslator.java | 280 +++++++++++++++
 .../protobuf/ProtoSchemaTranslatorTest.java        |  77 ++++
 .../sdk/extensions/protobuf/TestProtoSchemas.java  | 397 +++++++++++++++++++++
 .../src/test/proto/proto3_schema_messages.proto    | 123 +++++++
 14 files changed, 1296 insertions(+), 38 deletions(-)
 create mode 100644 sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoSchemaLogicalTypes.java
 create mode 100644 sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoSchemaTranslator.java
 create mode 100644 sdks/java/extensions/protobuf/src/test/java/org/apache/beam/sdk/extensions/protobuf/ProtoSchemaTranslatorTest.java
 create mode 100644 sdks/java/extensions/protobuf/src/test/java/org/apache/beam/sdk/extensions/protobuf/TestProtoSchemas.java
 create mode 100644 sdks/java/extensions/protobuf/src/test/proto/proto3_schema_messages.proto