[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 <taki...@apache.org> Authored: Mon Aug 7 14:05:04 2017 -0700 Committer: Tyler Akidau <taki...@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(-) ----------------------------------------------------------------------