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