You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2018/03/10 20:21:37 UTC
[beam] 01/01: Merge pull request #4802: [BEAM-3785][SQL] Add
support for arrays
This is an automated email from the ASF dual-hosted git repository.
kenn pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit be520691cd80b8b49b98474bab1c05dbd7baac68
Merge: 20b13e9 5e032cb
Author: Kenn Knowles <ke...@kennknowles.com>
AuthorDate: Sat Mar 10 12:21:31 2018 -0800
Merge pull request #4802: [BEAM-3785][SQL] Add support for arrays
.../main/java/org/apache/beam/sdk/values/Row.java | 10 +
.../apache/beam/sdk/extensions/sql/RowSqlType.java | 4 +
.../beam/sdk/extensions/sql/SqlTypeCoder.java | 47 ++++-
.../beam/sdk/extensions/sql/SqlTypeCoders.java | 5 +
.../sql/impl/interpreter/BeamSqlFnExecutor.java | 97 ++++++---
.../interpreter/operator/BeamSqlPrimitive.java | 2 +
.../operator/array/BeamSqlArrayExpression.java | 57 ++++++
.../operator/array/BeamSqlArrayItemExpression.java | 51 +++++
.../interpreter/operator/array/package-info.java | 26 +++
.../collection/BeamSqlCardinalityExpression.java | 52 +++++
.../collection/BeamSqlSingleElementExpression.java | 64 ++++++
.../operator/collection/package-info.java | 26 +++
.../extensions/sql/impl/utils/CalciteUtils.java | 68 +++++-
.../beam/sdk/extensions/sql/BeamSqlArrayTest.java | 228 +++++++++++++++++++++
.../operator/array/BeamSqlArrayExpressionTest.java | 79 +++++++
.../array/BeamSqlArrayItemExpressionTest.java | 96 +++++++++
.../BeamSqlCardinalityExpressionTest.java | 91 ++++++++
.../BeamSqlSingleElementExpressionTest.java | 93 +++++++++
18 files changed, 1058 insertions(+), 38 deletions(-)
--
To stop receiving notification emails like this one, please contact
kenn@apache.org.