[BEAM-301] This closes #2479
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/f1c2b654 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/f1c2b654 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/f1c2b654 Branch: refs/heads/DSL_SQL Commit: f1c2b6540652156ad7c51ec89a933aacb8c6dab6 Parents: 3625dbd 7867ce6 Author: Jean-Baptiste Onofré <[email protected]> Authored: Wed Apr 12 22:00:53 2017 +0200 Committer: Jean-Baptiste Onofré <[email protected]> Committed: Wed Apr 12 22:00:53 2017 +0200 ---------------------------------------------------------------------- dsls/pom.xml | 5 +- dsls/sql/README.md | 24 ++ dsls/sql/pom.xml | 166 +++++++++++++ .../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 ++ dsls/sql/src/main/resources/log4j.properties | 23 ++ .../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 ++++++++++ 52 files changed, 3441 insertions(+), 2 deletions(-) ----------------------------------------------------------------------
