This closes #3583
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/97a156c3 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/97a156c3 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/97a156c3 Branch: refs/heads/DSL_SQL Commit: 97a156c30fbe4b0f1c12b1b3946e8503fccca21a Parents: bff2149 c544566 Author: JingsongLi <[email protected]> Authored: Wed Jul 19 21:39:16 2017 +0800 Committer: JingsongLi <[email protected]> Committed: Wed Jul 19 21:39:16 2017 +0800 ---------------------------------------------------------------------- .../dsls/sql/interpreter/BeamSqlFnExecutor.java | 26 +- .../operator/BeamSqlCompareExpression.java | 93 ------ .../operator/BeamSqlEqualExpression.java | 48 --- .../operator/BeamSqlIsNotNullExpression.java | 51 --- .../operator/BeamSqlIsNullExpression.java | 51 --- .../BeamSqlLargerThanEqualExpression.java | 48 --- .../operator/BeamSqlLargerThanExpression.java | 48 --- .../BeamSqlLessThanEqualExpression.java | 48 --- .../operator/BeamSqlLessThanExpression.java | 48 --- .../operator/BeamSqlNotEqualExpression.java | 48 --- .../comparison/BeamSqlCompareExpression.java | 96 ++++++ .../comparison/BeamSqlEqualsExpression.java | 49 +++ .../BeamSqlGreaterThanExpression.java | 49 +++ .../BeamSqlGreaterThanOrEqualsExpression.java | 49 +++ .../comparison/BeamSqlIsNotNullExpression.java | 53 +++ .../comparison/BeamSqlIsNullExpression.java | 53 +++ .../comparison/BeamSqlLessThanExpression.java | 49 +++ .../BeamSqlLessThanOrEqualsExpression.java | 49 +++ .../comparison/BeamSqlNotEqualsExpression.java | 49 +++ .../operator/comparison/package-info.java | 22 ++ ...amSqlComparisonOperatorsIntegrationTest.java | 330 +++++++++++++++++++ .../sql/interpreter/BeamSqlFnExecutorTest.java | 8 +- .../operator/BeamNullExperssionTest.java | 2 + .../operator/BeamSqlCompareExpressionTest.java | 27 +- 24 files changed, 884 insertions(+), 510 deletions(-) ----------------------------------------------------------------------
