This closes #2530
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/ca876037 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/ca876037 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/ca876037 Branch: refs/heads/DSL_SQL Commit: ca8760373b37b540219301f1e719633956a787dc Parents: f1c2b65 529bc9d Author: Davor Bonaci <[email protected]> Authored: Tue Apr 18 14:40:40 2017 -0700 Committer: Davor Bonaci <[email protected]> Committed: Tue Apr 18 14:40:40 2017 -0700 ---------------------------------------------------------------------- dsls/pom.xml | 7 + .../beam/dsls/sql/example/BeamSqlExample.java | 103 ++++++++ .../beam/dsls/sql/example/package-info.java | 23 ++ .../interpreter/BeamSQLExpressionExecutor.java | 43 ++++ .../sql/interpreter/BeamSQLSpELExecutor.java | 127 +++++++++ .../dsls/sql/interpreter/CalciteToSpEL.java | 81 ++++++ .../beam/dsls/sql/interpreter/package-info.java | 22 ++ .../org/apache/beam/dsls/sql/package-info.java | 22 ++ .../dsls/sql/planner/BeamPipelineCreator.java | 86 +++++++ .../beam/dsls/sql/planner/BeamQueryPlanner.java | 159 ++++++++++++ .../dsls/sql/planner/BeamRelDataTypeSystem.java | 40 +++ .../beam/dsls/sql/planner/BeamRuleSets.java | 66 +++++ .../beam/dsls/sql/planner/BeamSQLRelUtils.java | 74 ++++++ .../beam/dsls/sql/planner/BeamSqlRunner.java | 94 +++++++ .../planner/BeamSqlUnsupportedException.java | 38 +++ .../planner/UnsupportedOperatorsVisitor.java | 28 ++ .../beam/dsls/sql/planner/package-info.java | 24 ++ .../apache/beam/dsls/sql/rel/BeamFilterRel.java | 71 +++++ .../apache/beam/dsls/sql/rel/BeamIOSinkRel.java | 76 ++++++ .../beam/dsls/sql/rel/BeamIOSourceRel.java | 60 +++++ .../dsls/sql/rel/BeamLogicalConvention.java | 72 ++++++ .../beam/dsls/sql/rel/BeamProjectRel.java | 83 ++++++ .../apache/beam/dsls/sql/rel/BeamRelNode.java | 38 +++ .../apache/beam/dsls/sql/rel/package-info.java | 23 ++ .../beam/dsls/sql/rule/BeamFilterRule.java | 49 ++++ .../beam/dsls/sql/rule/BeamIOSinkRule.java | 82 ++++++ .../beam/dsls/sql/rule/BeamIOSourceRule.java | 49 ++++ .../beam/dsls/sql/rule/BeamProjectRule.java | 50 ++++ .../apache/beam/dsls/sql/rule/package-info.java | 23 ++ .../beam/dsls/sql/schema/BaseBeamTable.java | 99 +++++++ .../apache/beam/dsls/sql/schema/BeamIOType.java | 28 ++ .../beam/dsls/sql/schema/BeamSQLRecordType.java | 74 ++++++ .../dsls/sql/schema/BeamSQLRecordTypeCoder.java | 88 +++++++ .../apache/beam/dsls/sql/schema/BeamSQLRow.java | 256 +++++++++++++++++++ .../beam/dsls/sql/schema/BeamSqlRowCoder.java | 149 +++++++++++ .../dsls/sql/schema/InvalidFieldException.java | 34 +++ .../schema/UnsupportedDataTypeException.java | 32 +++ .../sql/schema/kafka/BeamKafkaCSVTable.java | 127 +++++++++ .../dsls/sql/schema/kafka/BeamKafkaTable.java | 111 ++++++++ .../dsls/sql/schema/kafka/package-info.java | 22 ++ .../beam/dsls/sql/schema/package-info.java | 23 ++ .../dsls/sql/transform/BeamSQLFilterFn.java | 66 +++++ .../sql/transform/BeamSQLOutputToConsoleFn.java | 45 ++++ .../dsls/sql/transform/BeamSQLProjectFn.java | 72 ++++++ .../beam/dsls/sql/transform/package-info.java | 22 ++ .../beam/dsls/sql/example/BeamSqlExample.java | 102 -------- .../org/beam/dsls/sql/example/package-info.java | 23 -- .../interpreter/BeamSQLExpressionExecutor.java | 43 ---- .../sql/interpreter/BeamSQLSpELExecutor.java | 126 --------- .../dsls/sql/interpreter/CalciteToSpEL.java | 80 ------ .../beam/dsls/sql/interpreter/package-info.java | 22 -- .../java/org/beam/dsls/sql/package-info.java | 22 -- .../dsls/sql/planner/BeamPipelineCreator.java | 85 ------ .../beam/dsls/sql/planner/BeamQueryPlanner.java | 157 ------------ .../dsls/sql/planner/BeamRelDataTypeSystem.java | 40 --- .../org/beam/dsls/sql/planner/BeamRuleSets.java | 65 ----- .../beam/dsls/sql/planner/BeamSQLRelUtils.java | 73 ------ .../beam/dsls/sql/planner/BeamSqlRunner.java | 93 ------- .../planner/BeamSqlUnsupportedException.java | 38 --- .../planner/UnsupportedOperatorsVisitor.java | 28 -- .../org/beam/dsls/sql/planner/package-info.java | 24 -- .../org/beam/dsls/sql/rel/BeamFilterRel.java | 71 ----- .../org/beam/dsls/sql/rel/BeamIOSinkRel.java | 75 ------ .../org/beam/dsls/sql/rel/BeamIOSourceRel.java | 59 ----- .../dsls/sql/rel/BeamLogicalConvention.java | 72 ------ .../org/beam/dsls/sql/rel/BeamProjectRel.java | 82 ------ .../java/org/beam/dsls/sql/rel/BeamRelNode.java | 38 --- .../org/beam/dsls/sql/rel/package-info.java | 23 -- .../org/beam/dsls/sql/rule/BeamFilterRule.java | 49 ---- .../org/beam/dsls/sql/rule/BeamIOSinkRule.java | 81 ------ .../beam/dsls/sql/rule/BeamIOSourceRule.java | 49 ---- .../org/beam/dsls/sql/rule/BeamProjectRule.java | 50 ---- .../org/beam/dsls/sql/rule/package-info.java | 22 -- .../org/beam/dsls/sql/schema/BaseBeamTable.java | 99 ------- .../org/beam/dsls/sql/schema/BeamIOType.java | 28 -- .../beam/dsls/sql/schema/BeamSQLRecordType.java | 74 ------ .../dsls/sql/schema/BeamSQLRecordTypeCoder.java | 88 ------- .../org/beam/dsls/sql/schema/BeamSQLRow.java | 242 ------------------ .../beam/dsls/sql/schema/BeamSqlRowCoder.java | 149 ----------- .../dsls/sql/schema/InvalidFieldException.java | 30 --- .../schema/UnsupportedDataTypeException.java | 28 -- .../sql/schema/kafka/BeamKafkaCSVTable.java | 127 --------- .../dsls/sql/schema/kafka/BeamKafkaTable.java | 111 -------- .../dsls/sql/schema/kafka/package-info.java | 22 -- .../org/beam/dsls/sql/schema/package-info.java | 23 -- .../dsls/sql/transform/BeamSQLFilterFn.java | 66 ----- .../sql/transform/BeamSQLOutputToConsoleFn.java | 45 ---- .../dsls/sql/transform/BeamSQLProjectFn.java | 72 ------ .../beam/dsls/sql/transform/package-info.java | 22 -- .../beam/dsls/sql/planner/BasePlanner.java | 74 ++++++ .../sql/planner/BeamPlannerExplainTest.java | 68 +++++ .../dsls/sql/planner/BeamPlannerSubmitTest.java | 43 ++++ .../dsls/sql/planner/MockedBeamSQLTable.java | 123 +++++++++ .../org/beam/dsls/sql/planner/BasePlanner.java | 74 ------ .../sql/planner/BeamPlannerExplainTest.java | 68 ----- .../dsls/sql/planner/BeamPlannerSubmitTest.java | 42 --- .../dsls/sql/planner/MockedBeamSQLTable.java | 123 --------- 97 files changed, 3269 insertions(+), 3225 deletions(-) ----------------------------------------------------------------------
