This is an automated email from the ASF dual-hosted git repository. mingmxu pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git.
from a7819fe Merge pull request #5118: Identify side inputs by transform id and local name add 432979d support MAP in SQL schema add 83aa2e4 in MAP, key as primitive, and value can be primitive/array/map/row add 4ec9e60 use Collection for ARRAY type, and re-org `verify` code in `Row` add 1fab0a4 rebase as file conflict with #5089 add eae842f rename CollectionType to CollectionElementType new 3b3f944 Merge pull request #5079 from XuMingmin/BEAM-2990 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: .../java/org/apache/beam/sdk/coders/RowCoder.java | 17 ++- .../java/org/apache/beam/sdk/schemas/Schema.java | 58 ++++++--- .../apache/beam/sdk/util/RowJsonDeserializer.java | 2 +- .../apache/beam/sdk/util/RowJsonValidation.java | 4 +- .../main/java/org/apache/beam/sdk/values/Row.java | 79 +++++++++---- .../org/apache/beam/sdk/coders/RowCoderTest.java | 8 +- .../org/apache/beam/sdk/schemas/SchemaTest.java | 8 +- .../beam/sdk/util/RowJsonDeserializerTest.java | 4 +- .../java/org/apache/beam/sdk/values/RowTest.java | 108 ++++++++++++++++- .../beam/sdk/extensions/sql/RowSqlTypes.java | 27 ++++- .../sql/impl/interpreter/BeamSqlFnExecutor.java | 12 ++ .../interpreter/operator/BeamSqlPrimitive.java | 3 + .../operator/array/BeamSqlArrayItemExpression.java | 2 +- .../BeamSqlMapExpression.java} | 24 ++-- .../BeamSqlMapItemExpression.java} | 18 +-- .../operator/{row => map}/package-info.java | 5 +- .../extensions/sql/impl/utils/CalciteUtils.java | 39 ++++-- .../beam/sdk/extensions/sql/BeamSqlMapTest.java | 131 +++++++++++++++++++++ 18 files changed, 457 insertions(+), 92 deletions(-) copy sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/interpreter/operator/{array/BeamSqlArrayExpression.java => map/BeamSqlMapExpression.java} (74%) copy sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/interpreter/operator/{collection/BeamSqlCardinalityExpression.java => map/BeamSqlMapItemExpression.java} (77%) copy sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/interpreter/operator/{row => map}/package-info.java (94%) create mode 100644 sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/BeamSqlMapTest.java -- To stop receiving notification emails like this one, please contact ming...@apache.org.