Merge branch 'STORM-1443-on-top-of-STORM-1446' of https://github.com/HeartSaVioR/storm into STORM-1443-merge
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/33b78226 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/33b78226 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/33b78226 Branch: refs/heads/master Commit: 33b782265ca81bf1d8358b302d73b67366fa40aa Parents: f57f3bb 20cbd3a Author: Jungtaek Lim <kabh...@gmail.com> Authored: Fri Feb 3 10:22:56 2017 +0900 Committer: Jungtaek Lim <kabh...@gmail.com> Committed: Fri Feb 3 10:22:56 2017 +0900 ---------------------------------------------------------------------- docs/storm-sql.md | 12 +++++-- external/sql/README.md | 7 ++-- .../storm-sql-core/src/codegen/data/Parser.tdd | 1 + .../src/codegen/includes/parserImpls.ftl | 4 ++- .../jvm/org/apache/storm/sql/StormSqlImpl.java | 3 ++ .../sql/calcite/ParallelStreamableTable.java | 35 ++++++++++++++++++++ .../apache/storm/sql/compiler/CompilerUtil.java | 14 +++++++- .../apache/storm/sql/parser/SqlCreateTable.java | 24 +++++++++++--- .../trident/rel/TridentStreamScanRel.java | 8 +++-- .../planner/trident/rules/TridentScanRule.java | 12 +++++-- 10 files changed, 105 insertions(+), 15 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/33b78226/external/sql/storm-sql-core/src/jvm/org/apache/storm/sql/StormSqlImpl.java ----------------------------------------------------------------------