You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by da...@apache.org on 2017/04/18 21:41:03 UTC
[5/5] beam git commit: This closes #2530
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 <da...@google.com>
Authored: Tue Apr 18 14:40:40 2017 -0700
Committer: Davor Bonaci <da...@google.com>
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(-)
----------------------------------------------------------------------