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