This closes #2656
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a6845a35 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a6845a35 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/a6845a35 Branch: refs/heads/DSL_SQL Commit: a6845a35fc2a4091dcef24f231c6d3a418561e6f Parents: aa07a1d 464cc27 Author: Davor Bonaci <[email protected]> Authored: Thu May 4 00:12:55 2017 -0700 Committer: Davor Bonaci <[email protected]> Committed: Thu May 4 00:12:55 2017 -0700 ---------------------------------------------------------------------- dsls/sql/pom.xml | 47 ++++++- .../beam/dsls/sql/example/BeamSqlExample.java | 5 - .../exception/BeamInvalidOperatorException.java | 34 +++++ .../exception/BeamSqlUnsupportedException.java | 34 +++++ .../sql/exception/InvalidFieldException.java | 34 +++++ .../beam/dsls/sql/exception/package-info.java | 23 +++ .../dsls/sql/interpreter/BeamSQLFnExecutor.java | 140 +++++++++++++++++++ .../sql/interpreter/BeamSQLSpELExecutor.java | 127 ----------------- .../dsls/sql/interpreter/CalciteToSpEL.java | 81 ----------- .../operator/BeamSqlAndExpression.java | 60 ++++++++ .../operator/BeamSqlCompareExpression.java | 94 +++++++++++++ .../operator/BeamSqlEqualExpression.java | 48 +++++++ .../interpreter/operator/BeamSqlExpression.java | 62 ++++++++ .../operator/BeamSqlInputRefExpression.java | 46 ++++++ .../operator/BeamSqlIsNotNullExpression.java | 51 +++++++ .../operator/BeamSqlIsNullExpression.java | 51 +++++++ .../BeamSqlLargerThanEqualExpression.java | 49 +++++++ .../operator/BeamSqlLargerThanExpression.java | 49 +++++++ .../BeamSqlLessThanEqualExpression.java | 49 +++++++ .../operator/BeamSqlLessThanExpression.java | 49 +++++++ .../operator/BeamSqlNotEqualExpression.java | 48 +++++++ .../operator/BeamSqlOrExpression.java | 60 ++++++++ .../interpreter/operator/BeamSqlPrimitive.java | 102 ++++++++++++++ .../sql/interpreter/operator/package-info.java | 22 +++ .../beam/dsls/sql/planner/BeamQueryPlanner.java | 8 +- .../beam/dsls/sql/planner/BeamSqlRunner.java | 15 +- .../planner/BeamSqlUnsupportedException.java | 38 ----- .../apache/beam/dsls/sql/rel/BeamFilterRel.java | 4 +- .../beam/dsls/sql/rel/BeamProjectRel.java | 4 +- .../beam/dsls/sql/schema/BaseBeamTable.java | 5 - .../beam/dsls/sql/schema/BeamSQLRecordType.java | 4 - .../dsls/sql/schema/BeamSQLRecordTypeCoder.java | 15 +- .../apache/beam/dsls/sql/schema/BeamSQLRow.java | 76 ++++++---- .../beam/dsls/sql/schema/BeamSqlRowCoder.java | 48 ++++--- .../dsls/sql/schema/InvalidFieldException.java | 34 ----- .../sql/schema/kafka/BeamKafkaCSVTable.java | 5 - .../dsls/sql/schema/kafka/BeamKafkaTable.java | 5 - .../dsls/sql/transform/BeamSQLFilterFn.java | 4 - .../sql/transform/BeamSQLOutputToConsoleFn.java | 4 - .../dsls/sql/transform/BeamSQLProjectFn.java | 5 - .../sql/interpreter/BeamSQLFnExecutorTest.java | 101 +++++++++++++ .../interpreter/BeamSQLFnExecutorTestBase.java | 91 ++++++++++++ .../operator/BeamNullExperssionTest.java | 53 +++++++ .../operator/BeamSqlAndOrExpressionTest.java | 59 ++++++++ .../operator/BeamSqlCompareExpressionTest.java | 108 ++++++++++++++ .../operator/BeamSqlInputRefExpressionTest.java | 58 ++++++++ .../operator/BeamSqlPrimitiveTest.java | 60 ++++++++ .../beam/dsls/sql/planner/BasePlanner.java | 28 +++- .../sql/planner/BeamPlannerExplainTest.java | 5 +- .../dsls/sql/planner/BeamPlannerSubmitTest.java | 7 +- .../dsls/sql/planner/MockedBeamSQLTable.java | 14 +- 51 files changed, 1803 insertions(+), 420 deletions(-) ----------------------------------------------------------------------
