This is an automated email from the ASF dual-hosted git repository.
mingmxu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 3b3f944d4b6aad10a20bc466f75da2e9210192ff
Merge: a7819fe eae842f
Author: XuMingmin <xuming...@users.noreply.github.com>
AuthorDate: Mon Apr 16 11:49:34 2018 -0700
Merge pull request #5079 from XuMingmin/BEAM-2990
[BEAM-2990] support MAP in SQL schema
.../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} | 34 +++---
.../BeamSqlMapItemExpression.java} | 17 +--
.../interpreter/operator/map/package-info.java | 26 ++++
.../extensions/sql/impl/utils/CalciteUtils.java | 39 ++++--
.../beam/sdk/extensions/sql/BeamSqlMapTest.java | 131 +++++++++++++++++++++
18 files changed, 489 insertions(+), 90 deletions(-)
--
To stop receiving notification emails like this one, please contact
ming...@apache.org.
