beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [beam] 01/01: Merge pull request #5428: [BEAM-4167] Implement UNNEST operator for SQL
Date Fri, 25 May 2018 20:21:16 GMT
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 1b7be6e3040c48547caa73b670242af43dd5ec80
Merge: 795f064 b7ea0ed
Author: Kenn Knowles <kenn@kennknowles.com>
AuthorDate: Fri May 25 13:21:09 2018 -0700

    Merge pull request #5428: [BEAM-4167] Implement UNNEST operator for SQL

 .../interpreter/BeamSqlExpressionExecutor.java     |   4 +-
 .../sql/impl/interpreter/BeamSqlFnExecutor.java    |  13 +-
 .../operator/BeamSqlCaseExpression.java            |  12 +-
 .../operator/BeamSqlCastExpression.java            |  29 ++--
 ...n.java => BeamSqlCorrelVariableExpression.java} |  30 ++--
 .../operator/BeamSqlDefaultExpression.java         |   4 +-
 .../interpreter/operator/BeamSqlDotExpression.java |   8 +-
 .../interpreter/operator/BeamSqlExpression.java    |   9 +-
 .../operator/BeamSqlInputRefExpression.java        |   4 +-
 .../interpreter/operator/BeamSqlPrimitive.java     |   9 +-
 .../interpreter/operator/BeamSqlUdfExpression.java |   6 +-
 .../operator/BeamSqlWindowEndExpression.java       |   4 +-
 .../operator/BeamSqlWindowExpression.java          |   6 +-
 .../operator/BeamSqlWindowStartExpression.java     |   4 +-
 .../arithmetic/BeamSqlArithmeticExpression.java    |  10 +-
 .../operator/array/BeamSqlArrayExpression.java     |   6 +-
 .../operator/array/BeamSqlArrayItemExpression.java |   8 +-
 .../collection/BeamSqlCardinalityExpression.java   |   8 +-
 .../collection/BeamSqlSingleElementExpression.java |   6 +-
 .../comparison/BeamSqlCompareExpression.java       |   8 +-
 .../comparison/BeamSqlIsNotNullExpression.java     |   6 +-
 .../comparison/BeamSqlIsNullExpression.java        |   6 +-
 .../date/BeamSqlCurrentDateExpression.java         |   4 +-
 .../date/BeamSqlCurrentTimeExpression.java         |   4 +-
 .../date/BeamSqlCurrentTimestampExpression.java    |   4 +-
 .../operator/date/BeamSqlDateCeilExpression.java   |   6 +-
 .../operator/date/BeamSqlDateFloorExpression.java  |   6 +-
 .../date/BeamSqlDatetimeMinusExpression.java       |   5 +-
 .../date/BeamSqlDatetimePlusExpression.java        |  20 ++-
 .../operator/date/BeamSqlExtractExpression.java    |   6 +-
 .../date/BeamSqlIntervalMultiplyExpression.java    |  12 +-
 .../BeamSqlTimestampMinusIntervalExpression.java   |   8 +-
 .../BeamSqlTimestampMinusTimestampExpression.java  |  10 +-
 .../operator/logical/BeamSqlAndExpression.java     |   6 +-
 .../operator/logical/BeamSqlNotExpression.java     |   6 +-
 .../operator/logical/BeamSqlOrExpression.java      |   6 +-
 .../operator/map/BeamSqlMapExpression.java         |   8 +-
 .../operator/map/BeamSqlMapItemExpression.java     |   9 +-
 .../operator/math/BeamSqlMathBinaryExpression.java |   8 +-
 .../operator/math/BeamSqlMathUnaryExpression.java  |   6 +-
 .../operator/math/BeamSqlPiExpression.java         |   4 +-
 .../operator/math/BeamSqlRandExpression.java       |   6 +-
 .../math/BeamSqlRandIntegerExpression.java         |   9 +-
 .../reinterpret/BeamSqlReinterpretExpression.java  |   7 +-
 .../operator/row/BeamSqlFieldAccessExpression.java |   6 +-
 .../string/BeamSqlCharLengthExpression.java        |   6 +-
 .../operator/string/BeamSqlConcatExpression.java   |   8 +-
 .../operator/string/BeamSqlInitCapExpression.java  |   6 +-
 .../operator/string/BeamSqlLowerExpression.java    |   6 +-
 .../operator/string/BeamSqlOverlayExpression.java  |  12 +-
 .../operator/string/BeamSqlPositionExpression.java |  17 +--
 .../string/BeamSqlSubstringExpression.java         |  17 +--
 .../operator/string/BeamSqlTrimExpression.java     |  13 +-
 .../operator/string/BeamSqlUpperExpression.java    |   6 +-
 .../sql/impl/planner/BeamQueryPlanner.java         |   1 +
 .../extensions/sql/impl/planner/BeamRuleSets.java  |   4 +
 .../extensions/sql/impl/rel/BeamUncollectRel.java  |  88 ++++++++++++
 .../sdk/extensions/sql/impl/rel/BeamUnnestRel.java | 158 +++++++++++++++++++++
 .../sql/impl/rule/BeamUncollectRule.java           |  49 +++++++
 .../extensions/sql/impl/rule/BeamUnnestRule.java   |  58 ++++++++
 .../impl/transform/BeamAggregationTransforms.java  |   7 +-
 .../sql/impl/transform/BeamSqlFilterFn.java        |   3 +-
 .../sql/impl/transform/BeamSqlProjectFn.java       |   3 +-
 ...mSqlArrayTest.java => BeamSqlDslArrayTest.java} |  92 +++++++++++-
 .../operator/BeamNullExperssionTest.java           |   9 +-
 .../operator/BeamSqlAndOrExpressionTest.java       |  13 +-
 .../operator/BeamSqlCaseExpressionTest.java        |  13 +-
 .../operator/BeamSqlCastExpressionTest.java        |  41 ++++--
 .../operator/BeamSqlCompareExpressionTest.java     |  25 ++--
 .../operator/BeamSqlDotExpressionTest.java         |   7 +-
 .../operator/BeamSqlInputRefExpressionTest.java    |  13 +-
 .../interpreter/operator/BeamSqlPrimitiveTest.java |  16 ++-
 .../operator/BeamSqlReinterpretExpressionTest.java |   5 +-
 .../operator/BeamSqlUdfExpressionTest.java         |   3 +-
 .../BeamSqlArithmeticExpressionTest.java           |  83 ++++++++---
 .../operator/array/BeamSqlArrayExpressionTest.java |   4 +-
 .../array/BeamSqlArrayItemExpressionTest.java      |   5 +-
 .../BeamSqlCardinalityExpressionTest.java          |   5 +-
 .../BeamSqlSingleElementExpressionTest.java        |   5 +-
 .../date/BeamSqlCurrentDateExpressionTest.java     |   3 +-
 .../date/BeamSqlCurrentTimeExpressionTest.java     |   5 +-
 .../BeamSqlCurrentTimestampExpressionTest.java     |   5 +-
 .../date/BeamSqlDateCeilExpressionTest.java        |   5 +-
 .../date/BeamSqlDateFloorExpressionTest.java       |   5 +-
 .../date/BeamSqlDatetimeMinusExpressionTest.java   |   7 +-
 .../date/BeamSqlDatetimePlusExpressionTest.java    |   5 +-
 .../date/BeamSqlExtractExpressionTest.java         |  15 +-
 .../BeamSqlIntervalMultiplyExpressionTest.java     |   3 +-
 ...eamSqlTimestampMinusIntervalExpressionTest.java |   4 +-
 ...amSqlTimestampMinusTimestampExpressionTest.java |   3 +-
 .../operator/logical/BeamSqlNotExpressionTest.java |  10 +-
 .../math/BeamSqlMathBinaryExpressionTest.java      |  77 +++++++---
 .../math/BeamSqlMathUnaryExpressionTest.java       | 115 ++++++++++-----
 .../row/BeamSqlFieldAccessExpressionTest.java      |   9 +-
 .../string/BeamSqlCharLengthExpressionTest.java    |   7 +-
 .../string/BeamSqlConcatExpressionTest.java        |   4 +-
 .../string/BeamSqlInitCapExpressionTest.java       |  10 +-
 .../string/BeamSqlLowerExpressionTest.java         |   5 +-
 .../string/BeamSqlOverlayExpressionTest.java       |  13 +-
 .../string/BeamSqlPositionExpressionTest.java      |  13 +-
 .../string/BeamSqlSubstringExpressionTest.java     |  29 +++-
 .../operator/string/BeamSqlTrimExpressionTest.java |  14 +-
 .../string/BeamSqlUpperExpressionTest.java         |   5 +-
 103 files changed, 1182 insertions(+), 356 deletions(-)

-- 
To stop receiving notification emails like this one, please contact
kenn@apache.org.

Mime
View raw message