beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From da...@apache.org
Subject [3/3] beam git commit: This closes #2656
Date Thu, 04 May 2017 07:13:11 GMT
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 <davor@google.com>
Authored: Thu May 4 00:12:55 2017 -0700
Committer: Davor Bonaci <davor@google.com>
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(-)
----------------------------------------------------------------------



Mime
View raw message