This closes #3439
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ab4b1188 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ab4b1188 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/ab4b1188 Branch: refs/heads/DSL_SQL Commit: ab4b118869070e94a4205744d6d60525d3fa2882 Parents: bd99528 32fbc9c Author: Tyler Akidau <taki...@apache.org> Authored: Tue Jun 27 18:25:56 2017 -0700 Committer: Tyler Akidau <taki...@apache.org> Committed: Tue Jun 27 18:25:56 2017 -0700 ---------------------------------------------------------------------- dsls/pom.xml | 14 ++++++ dsls/sql/pom.xml | 48 +++++++++++++------- .../java/org/apache/beam/dsls/sql/BeamSql.java | 4 +- .../beam/dsls/sql/example/BeamSqlExample.java | 2 +- .../interpreter/operator/BeamSqlExpression.java | 2 +- .../interpreter/operator/BeamSqlPrimitive.java | 4 +- .../arithmetic/BeamSqlArithmeticExpression.java | 7 ++- .../arithmetic/BeamSqlDivideExpression.java | 3 ++ .../operator/logical/BeamSqlNotExpression.java | 1 - .../operator/math/BeamSqlAbsExpression.java | 2 + .../operator/math/BeamSqlRoundExpression.java | 3 +- .../operator/math/BeamSqlSignExpression.java | 2 + .../beam/dsls/sql/planner/BeamQueryPlanner.java | 2 +- .../apache/beam/dsls/sql/rel/BeamIOSinkRel.java | 3 +- .../beam/dsls/sql/rel/BeamIOSourceRel.java | 4 +- .../dsls/sql/schema/BeamPCollectionTable.java | 2 +- .../apache/beam/dsls/sql/schema/BeamSqlRow.java | 5 +- .../beam/dsls/sql/schema/BeamTableUtils.java | 4 +- .../transform/BeamSetOperatorsTransforms.java | 5 +- .../interpreter/BeamSqlFnExecutorTestBase.java | 2 +- 20 files changed, 76 insertions(+), 43 deletions(-) ----------------------------------------------------------------------