This closes #3557
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a452b802 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a452b802 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/a452b802 Branch: refs/heads/DSL_SQL Commit: a452b802008c44083afbbfaf79f65f20b5dcd03b Parents: 5fea746 bdea7a6 Author: JingsongLi <lzljs3620...@aliyun.com> Authored: Mon Jul 17 15:11:02 2017 +0800 Committer: JingsongLi <lzljs3620...@aliyun.com> Committed: Mon Jul 17 15:11:02 2017 +0800 ---------------------------------------------------------------------- .../dsls/sql/interpreter/BeamSqlFnExecutor.java | 3 + .../arithmetic/BeamSqlArithmeticExpression.java | 120 +++++++----- .../arithmetic/BeamSqlDivideExpression.java | 13 +- .../arithmetic/BeamSqlMinusExpression.java | 10 +- .../arithmetic/BeamSqlModExpression.java | 12 +- .../arithmetic/BeamSqlMultiplyExpression.java | 10 +- .../arithmetic/BeamSqlPlusExpression.java | 10 +- .../apache/beam/dsls/sql/schema/BeamSqlRow.java | 182 ++++--------------- .../beam/dsls/sql/schema/BeamSqlRowCoder.java | 2 + .../beam/dsls/sql/utils/CalciteUtils.java | 1 + .../org/apache/beam/dsls/sql/TestUtils.java | 18 +- ...amSqlArithmeticOperatorsIntegrationTest.java | 162 +++++++++++++++++ ...mSqlBuiltinFunctionsIntegrationTestBase.java | 168 +++++++++++++++++ .../BeamSqlStringFunctionsIntegrationTest.java | 85 +++------ .../BeamSqlArithmeticExpressionTest.java | 42 ++--- .../beam/dsls/sql/mock/MockedBoundedTable.java | 10 +- .../dsls/sql/mock/MockedUnboundedTable.java | 3 +- 17 files changed, 522 insertions(+), 329 deletions(-) ----------------------------------------------------------------------