[beam] branch master updated (0351b49 -> b564239)

[re...@apache.org]

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 0351b49  Merge pull request #1071: [BEAM-8280] Enable type hint annotations
     new 7a4985a  switch cogbk to use Beam transform
     new 80de858  finish join
     new 32cdd42  support side-input joins
     new ee13904  support side-input joins
     new bbac923  spotless
     new 462974e  make FieldAccessDescriptor always be field-insertion order
     new 8420598  fix side-input joins
     new 165fd7b  fix bug
     new a6f0ce3  remove obsolete test
     new fafd96e  add javadoc
     new 4460b84  add unit tests
     new 37b1fba  update sql transform
     new b564239  Merge pull request #11041 from reuvenlax/use_beam_join_api_in_sql

The 26133 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:
 .../beam/sdk/schemas/FieldAccessDescriptor.java    | 125 +++--
 .../java/org/apache/beam/sdk/schemas/Schema.java   |  13 +-
 .../beam/sdk/schemas/transforms/CoGroup.java       | 516 +++++++++++++--------
 .../apache/beam/sdk/schemas/transforms/Join.java   |  30 +-
 .../apache/beam/sdk/schemas/transforms/Select.java | 155 +++++--
 .../beam/sdk/schemas/utils/SelectHelpers.java      |   2 +-
 .../sdk/schemas/FieldAccessDescriptorTest.java     |  10 -
 .../beam/sdk/schemas/transforms/CoGroupTest.java   |  90 +++-
 .../beam/sdk/schemas/transforms/JoinTest.java      |  45 +-
 .../beam/sdk/schemas/transforms/SelectTest.java    |  65 +++
 .../extensions/sql/impl/rel/BeamCoGBKJoinRel.java  | 134 +++---
 .../sdk/extensions/sql/impl/rel/BeamJoinRel.java   | 139 ------
 .../sql/impl/rel/BeamSideInputJoinRel.java         | 136 +++---
 .../sql/impl/rule/BeamIOPushDownRule.java          |   5 -
 .../sql/impl/transform/BeamJoinTransforms.java     | 136 ++----
 .../sql/meta/provider/mongodb/MongoDbTable.java    |   4 +-
 .../sql/meta/provider/test/TestTableProvider.java  |   4 +-
 17 files changed, 937 insertions(+), 672 deletions(-)