You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lz...@apache.org on 2017/07/17 07:11:33 UTC
[3/3] beam git commit: This closes #3557
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 <lz...@aliyun.com>
Authored: Mon Jul 17 15:11:02 2017 +0800
Committer: JingsongLi <lz...@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(-)
----------------------------------------------------------------------