You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jb...@apache.org on 2017/04/12 20:01:28 UTC
[3/3] beam git commit: [BEAM-301] This closes #2479
[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� <jb...@apache.org>
Authored: Wed Apr 12 22:00:53 2017 +0200
Committer: Jean-Baptiste Onofr� <jb...@apache.org>
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(-)
----------------------------------------------------------------------