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:36 UTC
[beam] branch master updated (20b13e9 -> be52069)
This is an automated email from the ASF dual-hosted git repository.
kenn pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 20b13e9 Merge pull request #4841: BEAM-3803: Dataflow runner implements metrics contract
add 594d5e1 [SQL] Add support for ARRAY expression
add 925ca66 [SQL] Support ARRAY in projections
add 21a6c78 [SQL] Implement array elements access expression
add 581c5d1 [SQL] Add support for ELEMENT(collection) function
add 5e032cb [SQL] Add support for CARDINALITY(collection)
new be52069 Merge pull request #4802: [BEAM-3785][SQL] Add support for arrays
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:
.../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 +
.../BeamSqlArrayExpression.java} | 36 ++--
.../BeamSqlArrayItemExpression.java} | 30 ++-
.../interpreter/operator/array}/package-info.java | 4 +-
.../BeamSqlCardinalityExpression.java} | 31 ++-
.../BeamSqlSingleElementExpression.java} | 41 ++--
.../operator/collection}/package-info.java | 4 +-
.../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, 857 insertions(+), 109 deletions(-)
copy sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/interpreter/operator/{math/BeamSqlRandExpression.java => array/BeamSqlArrayExpression.java} (68%)
copy sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/interpreter/operator/{math/BeamSqlRandExpression.java => array/BeamSqlArrayItemExpression.java} (69%)
copy {runners/core-java/src/main/java/org/apache/beam/runners/core => sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/interpreter/operator/array}/package-info.java (88%)
copy sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/interpreter/operator/{math/BeamSqlRandExpression.java => collection/BeamSqlCardinalityExpression.java} (69%)
copy sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/interpreter/operator/{math/BeamSqlRandExpression.java => collection/BeamSqlSingleElementExpression.java} (57%)
copy {runners/core-java/src/main/java/org/apache/beam/runners/core => sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/interpreter/operator/collection}/package-info.java (87%)
create mode 100644 sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/BeamSqlArrayTest.java
create mode 100644 sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/impl/interpreter/operator/array/BeamSqlArrayExpressionTest.java
create mode 100644 sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/impl/interpreter/operator/array/BeamSqlArrayItemExpressionTest.java
create mode 100644 sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/impl/interpreter/operator/collection/BeamSqlCardinalityExpressionTest.java
create mode 100644 sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/impl/interpreter/operator/collection/BeamSqlSingleElementExpressionTest.java
--
To stop receiving notification emails like this one, please contact
kenn@apache.org.
[beam] 01/01: Merge pull request #4802: [BEAM-3785][SQL] Add
support for arrays
Posted by ke...@apache.org.
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.