Merge branch 'STORM-2845'
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/e7fdd67a Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/e7fdd67a Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/e7fdd67a Branch: refs/heads/master Commit: e7fdd67a6ad7b2fb9b30610a4613f0a132311cdb Parents: 5bdf3dd 1dcd12d Author: Jungtaek Lim <[email protected]> Authored: Fri Dec 15 18:55:23 2017 +0900 Committer: Jungtaek Lim <[email protected]> Committed: Fri Dec 15 18:55:23 2017 +0900 ---------------------------------------------------------------------- .../src/jvm/org/apache/storm/sql/StormSql.java | 8 - .../org/apache/storm/sql/StormSqlContext.java | 172 +++++ .../jvm/org/apache/storm/sql/StormSqlImpl.java | 180 +---- .../standalone/BuiltinAggregateFunctions.java | 238 ------- .../backends/standalone/PlanCompiler.java | 139 ---- .../standalone/PostOrderRelNodeVisitor.java | 132 ---- .../backends/standalone/RelNodeCompiler.java | 484 ------------- .../test/org/apache/storm/sql/SqlTestUtil.java | 65 ++ .../storm/sql/StormSqlLocalClusterImpl.java | 80 +++ .../test/org/apache/storm/sql/TestStormSql.java | 676 +++++++------------ .../storm/sql/compiler/TestExprSemantic.java | 410 ----------- .../backends/standalone/TestCompilerUtils.java | 183 ----- .../backends/standalone/TestPlanCompiler.java | 104 --- .../standalone/TestRelNodeCompiler.java | 64 -- .../backends/trident/TestExpressions.java | 359 ++++++++++ .../backends/trident/TestPlanCompiler.java | 119 ++-- .../storm/sql/hdfs/HdfsDataSourcesProvider.java | 7 - .../sql/kafka/KafkaDataSourcesProvider.java | 7 - .../sql/mongodb/MongoDataSourcesProvider.java | 7 - .../sql/redis/RedisDataSourcesProvider.java | 6 - .../sql/runtime/AbstractChannelHandler.java | 53 -- .../sql/runtime/AbstractValuesProcessor.java | 45 -- .../storm/sql/runtime/ChannelContext.java | 34 - .../storm/sql/runtime/ChannelHandler.java | 42 -- .../org/apache/storm/sql/runtime/Channels.java | 110 --- .../apache/storm/sql/runtime/DataSource.java | 28 - .../storm/sql/runtime/DataSourcesProvider.java | 14 - .../storm/sql/runtime/DataSourcesRegistry.java | 19 - .../storm/sql/runtime/StormSqlFunctions.java | 48 -- .../socket/SocketDataSourcesProvider.java | 6 - .../test/org/apache/storm/sql/TestUtils.java | 190 ++---- 31 files changed, 1048 insertions(+), 2981 deletions(-) ----------------------------------------------------------------------
