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
[email protected].
