You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by ka...@apache.org on 2017/02/03 01:02:36 UTC
[2/3] storm git commit: Merge branch
'STORM-2148-on-top-of-STORM-1446' of https://github.com/HeartSaVioR/storm
into STORM-2148-merge
Merge branch 'STORM-2148-on-top-of-STORM-1446' of https://github.com/HeartSaVioR/storm into STORM-2148-merge
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/ee6c6b59
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/ee6c6b59
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/ee6c6b59
Branch: refs/heads/master
Commit: ee6c6b59a6d28dba11782ba76dab94bc853550bf
Parents: a185716 d76c5d5
Author: Jungtaek Lim <ka...@gmail.com>
Authored: Fri Feb 3 09:49:45 2017 +0900
Committer: Jungtaek Lim <ka...@gmail.com>
Committed: Fri Feb 3 09:49:45 2017 +0900
----------------------------------------------------------------------
.../storm/sql/AbstractTridentProcessor.java | 58 +++++
.../jvm/org/apache/storm/sql/StormSqlImpl.java | 25 +-
.../RexNodeToBlockStatementCompiler.java | 107 ---------
.../sql/compiler/RexNodeToJavaCodeCompiler.java | 231 +++++++++++++++++++
.../backends/standalone/RelNodeCompiler.java | 13 +-
.../apache/storm/sql/planner/StormRelUtils.java | 6 +
.../storm/sql/planner/trident/QueryPlanner.java | 9 +-
.../sql/planner/trident/TridentPlanCreator.java | 49 +++-
.../sql/planner/trident/rel/TridentCalcRel.java | 19 +-
.../planner/trident/rel/TridentFilterRel.java | 9 +-
.../planner/trident/rel/TridentProjectRel.java | 9 +-
.../backends/trident/TestPlanCompiler.java | 9 +-
.../calcite/DebuggableExecutableExpression.java | 45 ++++
.../runtime/calcite/ExecutableExpression.java | 31 +++
.../trident/AbstractTridentProcessor.java | 48 ----
.../trident/functions/EvaluationCalc.java | 70 ++----
.../trident/functions/EvaluationFilter.java | 39 +---
.../trident/functions/EvaluationFunction.java | 40 +---
18 files changed, 520 insertions(+), 297 deletions(-)
----------------------------------------------------------------------