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 2020/03/24 00:38:47 UTC

[beam] branch master updated (913c9f8 -> fc6cef9)

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 913c9f8  Merge pull request #11198 from [BEAM-7923] Obfuscates display ids
     add fc6cef9  Merge pull request #11074: Store logical type values in Row instead of base values

No new revisions were added by this update.

Summary of changes:
 .../apache/beam/sdk/coders/RowCoderGenerator.java  | 219 ++++-------
 .../beam/sdk/schemas/FromRowUsingCreator.java      |  15 +-
 .../org/apache/beam/sdk/schemas/SchemaCoder.java   |  60 +--
 .../beam/sdk/schemas/SchemaCoderHelpers.java       | 168 +++++++++
 .../sdk/schemas/logicaltypes/EnumerationType.java  |  30 +-
 .../beam/sdk/schemas/logicaltypes/OneOfType.java   |  35 +-
 .../apache/beam/sdk/schemas/transforms/Group.java  | 252 +++++++++++--
 .../sdk/schemas/transforms/SchemaAggregateFn.java  |  48 ++-
 .../apache/beam/sdk/schemas/utils/AvroUtils.java   |   3 +-
 .../beam/sdk/schemas/utils/ByteBuddyUtils.java     |  27 +-
 .../beam/sdk/schemas/utils/ConvertHelpers.java     |   3 +-
 .../apache/beam/sdk/schemas/utils/POJOUtils.java   |   2 +-
 .../main/java/org/apache/beam/sdk/values/Row.java  |  61 +++-
 .../org/apache/beam/sdk/values/RowWithGetters.java |   9 +-
 .../apache/beam/sdk/values/SchemaVerification.java |   3 +-
 .../org/apache/beam/sdk/coders/RowCoderTest.java   |  70 ++++
 .../apache/beam/sdk/schemas/AvroSchemaTest.java    |   2 +-
 .../beam/sdk/schemas/JavaFieldSchemaTest.java      |  57 ++-
 .../sdk/schemas/logicaltypes/LogicalTypesTest.java |  12 +-
 .../beam/sdk/schemas/transforms/GroupTest.java     | 406 ++++++++++-----------
 .../beam/sdk/schemas/utils/SchemaTestUtils.java    | 138 ++++++-
 .../apache/beam/sdk/schemas/utils/TestPOJOs.java   |  13 +-
 .../protobuf/ProtoDynamicMessageSchema.java        |  19 +-
 .../sql/impl/rel/BeamAggregationRel.java           |  17 +-
 .../sdk/extensions/sql/impl/rel/BeamCalcRel.java   |  78 ++--
 .../sql/impl/rel/BeamEnumerableConverter.java      |   2 +-
 .../sdk/extensions/sql/impl/rel/BeamSortRel.java   |   4 +-
 .../extensions/sql/impl/rel/BeamUncollectRel.java  |   2 +-
 .../sdk/extensions/sql/impl/rel/BeamUnnestRel.java |   6 +-
 .../extensions/sql/impl/schema/BeamTableUtils.java |   2 +-
 .../sql/impl/transform/BeamJoinTransforms.java     |   8 +-
 .../sql/impl/transform/agg/CovarianceFn.java       |   4 +-
 .../sdk/extensions/sql/BeamComplexTypeTest.java    |   3 +-
 .../sql/impl/schema/BeamSqlRowCoderTest.java       |   4 +-
 .../extensions/sql/zetasql/BeamZetaSqlCalcRel.java |   2 +-
 .../sdk/extensions/sql/zetasql/ZetaSqlUtils.java   |   4 +-
 36 files changed, 1200 insertions(+), 588 deletions(-)
 create mode 100644 sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SchemaCoderHelpers.java