You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ta...@apache.org on 2017/08/07 21:06:11 UTC
[4/4] beam git commit: [BEAM-2722] This closes #3689
[BEAM-2722] This closes #3689
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/79880b6a
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/79880b6a
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/79880b6a
Branch: refs/heads/DSL_SQL
Commit: 79880b6ab71936b6681c581128db87cc69ab6395
Parents: 8f922f7 c0b1fed
Author: Tyler Akidau <ta...@apache.org>
Authored: Mon Aug 7 14:05:04 2017 -0700
Committer: Tyler Akidau <ta...@apache.org>
Committed: Mon Aug 7 14:05:04 2017 -0700
----------------------------------------------------------------------
.../apache/beam/sdk/coders/BeamRecordCoder.java | 7 --
.../org/apache/beam/sdk/values/BeamRecord.java | 36 +-------
.../interpreter/BeamSqlExpressionExecutor.java | 5 +-
.../sql/impl/interpreter/BeamSqlFnExecutor.java | 5 +-
.../operator/BeamSqlCaseExpression.java | 9 +-
.../operator/BeamSqlCastExpression.java | 31 +++----
.../interpreter/operator/BeamSqlExpression.java | 9 +-
.../operator/BeamSqlInputRefExpression.java | 3 +-
.../interpreter/operator/BeamSqlPrimitive.java | 5 +-
.../operator/BeamSqlReinterpretExpression.java | 7 +-
.../operator/BeamSqlUdfExpression.java | 5 +-
.../operator/BeamSqlWindowEndExpression.java | 12 ++-
.../operator/BeamSqlWindowExpression.java | 5 +-
.../operator/BeamSqlWindowStartExpression.java | 12 ++-
.../arithmetic/BeamSqlArithmeticExpression.java | 8 +-
.../comparison/BeamSqlCompareExpression.java | 7 +-
.../comparison/BeamSqlIsNotNullExpression.java | 5 +-
.../comparison/BeamSqlIsNullExpression.java | 5 +-
.../date/BeamSqlCurrentDateExpression.java | 3 +-
.../date/BeamSqlCurrentTimeExpression.java | 3 +-
.../date/BeamSqlCurrentTimestampExpression.java | 3 +-
.../date/BeamSqlDateCeilExpression.java | 5 +-
.../date/BeamSqlDateFloorExpression.java | 5 +-
.../operator/date/BeamSqlExtractExpression.java | 5 +-
.../operator/logical/BeamSqlAndExpression.java | 5 +-
.../operator/logical/BeamSqlNotExpression.java | 7 +-
.../operator/logical/BeamSqlOrExpression.java | 5 +-
.../math/BeamSqlMathBinaryExpression.java | 6 +-
.../math/BeamSqlMathUnaryExpression.java | 6 +-
.../operator/math/BeamSqlPiExpression.java | 3 +-
.../operator/math/BeamSqlRandExpression.java | 5 +-
.../math/BeamSqlRandIntegerExpression.java | 7 +-
.../string/BeamSqlCharLengthExpression.java | 5 +-
.../string/BeamSqlConcatExpression.java | 7 +-
.../string/BeamSqlInitCapExpression.java | 5 +-
.../operator/string/BeamSqlLowerExpression.java | 5 +-
.../string/BeamSqlOverlayExpression.java | 11 +--
.../string/BeamSqlPositionExpression.java | 9 +-
.../string/BeamSqlSubstringExpression.java | 9 +-
.../operator/string/BeamSqlTrimExpression.java | 11 +--
.../operator/string/BeamSqlUpperExpression.java | 5 +-
.../transform/BeamAggregationTransforms.java | 7 +-
.../sql/impl/transform/BeamSqlFilterFn.java | 5 +-
.../sql/impl/transform/BeamSqlProjectFn.java | 3 +-
.../sql/BeamSqlDslAggregationTest.java | 17 ----
.../operator/BeamNullExperssionTest.java | 8 +-
.../operator/BeamSqlAndOrExpressionTest.java | 8 +-
.../operator/BeamSqlCaseExpressionTest.java | 6 +-
.../operator/BeamSqlCastExpressionTest.java | 24 +++---
.../operator/BeamSqlCompareExpressionTest.java | 24 +++---
.../operator/BeamSqlInputRefExpressionTest.java | 12 +--
.../operator/BeamSqlPrimitiveTest.java | 10 +--
.../BeamSqlReinterpretExpressionTest.java | 2 +-
.../operator/BeamSqlUdfExpressionTest.java | 2 +-
.../BeamSqlArithmeticExpressionTest.java | 46 +++++-----
.../date/BeamSqlCurrentDateExpressionTest.java | 2 +-
.../date/BeamSqlCurrentTimeExpressionTest.java | 2 +-
.../BeamSqlCurrentTimestampExpressionTest.java | 2 +-
.../date/BeamSqlDateCeilExpressionTest.java | 4 +-
.../date/BeamSqlDateFloorExpressionTest.java | 4 +-
.../date/BeamSqlExtractExpressionTest.java | 14 +--
.../logical/BeamSqlNotExpressionTest.java | 6 +-
.../math/BeamSqlMathBinaryExpressionTest.java | 58 ++++++++-----
.../math/BeamSqlMathUnaryExpressionTest.java | 91 ++++++++++----------
.../string/BeamSqlCharLengthExpressionTest.java | 2 +-
.../string/BeamSqlConcatExpressionTest.java | 2 +-
.../string/BeamSqlInitCapExpressionTest.java | 6 +-
.../string/BeamSqlLowerExpressionTest.java | 2 +-
.../string/BeamSqlOverlayExpressionTest.java | 8 +-
.../string/BeamSqlPositionExpressionTest.java | 6 +-
.../string/BeamSqlSubstringExpressionTest.java | 14 +--
.../string/BeamSqlTrimExpressionTest.java | 8 +-
.../string/BeamSqlUpperExpressionTest.java | 2 +-
73 files changed, 366 insertions(+), 352 deletions(-)
----------------------------------------------------------------------