beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From reuven...@apache.org
Subject [beam] branch master updated (3400ba6 -> 8b20602)
Date Wed, 12 Dec 2018 21:16:11 GMT
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 3400ba6  Merge pull request #7229: [BEAM-5419] Add Flink multi-version builds
     add 2a40c57  Add remaining Schema support for AVRO records:   * Add support for SpecificRecord
using ByteBuddy codegen.   * Add helper methods for GenericRecord.   * Fix uncovered bugs
involving nullable support.
     add 0a74b17  Add period to sentence.
     new 8b20602  Merge pull request #7233:  [BEAM-4454] Add remaining functionality for AVRO
schemas

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 build.gradle                                       |   1 +
 ...y.java => AvroSpecificRecordGetterFactory.java} |  13 +-
 .../beam/sdk/schemas/AvroSpecificRecordSchema.java |  51 +++++
 ... AvroSpecificRecordUserTypeCreatorFactory.java} |  11 +-
 .../sdk/schemas/GetterBasedSchemaProvider.java     |  41 +---
 .../apache/beam/sdk/schemas/JavaBeanSchema.java    |   8 +-
 .../apache/beam/sdk/schemas/JavaFieldSchema.java   |   6 -
 .../java/org/apache/beam/sdk/schemas/Schema.java   |   8 +
 .../sdk/schemas/SetterBasedCreatorFactory.java     |  57 +++++
 .../beam/sdk/schemas/utils/AvroByteBuddyUtils.java | 123 +++++++++++
 ... AvroSpecificRecordTypeInformationFactory.java} |   7 +-
 .../apache/beam/sdk/schemas/utils/AvroUtils.java   | 243 ++++++++++++++++-----
 .../beam/sdk/schemas/utils/ByteBuddyUtils.java     |  50 +++++
 .../sdk/schemas/utils/JavaBeanGetterFactory.java   |   3 +-
 .../utils/JavaBeanTypeInformationFactory.java      |   3 +-
 .../beam/sdk/schemas/utils/JavaBeanUtils.java      |  43 ++--
 .../sdk/schemas/utils/StaticSchemaInference.java   |   6 +-
 .../avro/org/apache/beam/sdk/schemas/test.avsc     |  29 +++
 .../apache/beam/sdk/schemas/AvroSchemaTest.java    | 162 ++++++++++++++
 .../beam/sdk/schemas/utils/AvroUtilsTest.java      |  41 +++-
 .../beam/sdk/schemas/utils/JavaBeanUtilsTest.java  |  43 +++-
 21 files changed, 804 insertions(+), 145 deletions(-)
 copy sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/{utils/PojoValueGetterFactory.java
=> AvroSpecificRecordGetterFactory.java} (69%)
 create mode 100644 sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/AvroSpecificRecordSchema.java
 copy sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/{PojoTypeUserTypeCreatorFactory.java
=> AvroSpecificRecordUserTypeCreatorFactory.java} (72%)
 create mode 100644 sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SetterBasedCreatorFactory.java
 create mode 100644 sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/AvroByteBuddyUtils.java
 copy sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/{PojoValueTypeInformationFactory.java
=> AvroSpecificRecordTypeInformationFactory.java} (78%)
 create mode 100644 sdks/java/core/src/test/avro/org/apache/beam/sdk/schemas/test.avsc
 create mode 100644 sdks/java/core/src/test/java/org/apache/beam/sdk/schemas/AvroSchemaTest.java


Mime
View raw message