You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by sr...@apache.org on 2015/12/11 07:41:23 UTC
[4/6] storm git commit: Merge remote-tracking branch
'upstream/master' into STORM-1211
Merge remote-tracking branch 'upstream/master' into STORM-1211
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/cc009d4e
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/cc009d4e
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/cc009d4e
Branch: refs/heads/master
Commit: cc009d4eb44e0d5e644413d542742a7dc273ef45
Parents: 4c56eb7 ceb3a0c
Author: Satish Duggana <sd...@hortonworks.com>
Authored: Thu Dec 10 10:17:58 2015 +0530
Committer: Satish Duggana <sd...@hortonworks.com>
Committed: Thu Dec 10 10:17:58 2015 +0530
----------------------------------------------------------------------
CHANGELOG.md | 4 +
README.markdown | 5 +-
bin/storm.py | 16 +-
external/sql/README.md | 117 +++++
external/sql/pom.xml | 44 ++
external/sql/storm-sql-core/pom.xml | 261 ++++++++++
.../sql/storm-sql-core/src/codegen/config.fmpp | 23 +
.../storm-sql-core/src/codegen/data/Parser.tdd | 64 +++
.../src/codegen/includes/license.ftl | 17 +
.../src/codegen/includes/parserImpls.ftl | 86 ++++
.../src/jvm/org/apache/storm/sql/StormSql.java | 54 +++
.../jvm/org/apache/storm/sql/StormSqlImpl.java | 187 ++++++++
.../org/apache/storm/sql/StormSqlRunner.java | 44 ++
.../apache/storm/sql/compiler/CompilerUtil.java | 168 +++++++
.../apache/storm/sql/compiler/ExprCompiler.java | 471 +++++++++++++++++++
.../sql/compiler/PostOrderRelNodeVisitor.java | 122 +++++
.../backends/standalone/PlanCompiler.java | 132 ++++++
.../backends/standalone/RelNodeCompiler.java | 111 +++++
.../compiler/backends/trident/PlanCompiler.java | 201 ++++++++
.../backends/trident/RelNodeCompiler.java | 116 +++++
.../storm/sql/javac/CompilingClassLoader.java | 225 +++++++++
.../storm/sql/parser/ColumnConstraint.java | 42 ++
.../storm/sql/parser/ColumnDefinition.java | 44 ++
.../apache/storm/sql/parser/SqlCreateTable.java | 136 ++++++
.../apache/storm/sql/parser/SqlDDLKeywords.java | 27 ++
.../apache/storm/sql/parser/StormParser.java | 42 ++
.../apache/storm/sql/parser/UnparseUtil.java | 60 +++
.../test/org/apache/storm/sql/TestStormSql.java | 82 ++++
.../storm/sql/compiler/TestCompilerUtils.java | 64 +++
.../storm/sql/compiler/TestExprCompiler.java | 93 ++++
.../storm/sql/compiler/TestExprSemantic.java | 140 ++++++
.../backends/standalone/TestPlanCompiler.java | 69 +++
.../standalone/TestRelNodeCompiler.java | 62 +++
.../backends/trident/TestPlanCompiler.java | 116 +++++
.../apache/storm/sql/parser/TestSqlParser.java | 48 ++
external/sql/storm-sql-kafka/pom.xml | 111 +++++
.../org/apache/storm/sql/kafka/JsonScheme.java | 58 +++
.../apache/storm/sql/kafka/JsonSerializer.java | 56 +++
.../sql/kafka/KafkaDataSourcesProvider.java | 205 ++++++++
...apache.storm.sql.runtime.DataSourcesProvider | 16 +
.../storm/sql/kafka/TestJsonRepresentation.java | 50 ++
.../sql/kafka/TestKafkaDataSourcesProvider.java | 114 +++++
external/sql/storm-sql-runtime/pom.xml | 73 +++
.../sql/runtime/AbstractChannelHandler.java | 44 ++
.../sql/runtime/AbstractValuesProcessor.java | 49 ++
.../storm/sql/runtime/ChannelContext.java | 30 ++
.../storm/sql/runtime/ChannelHandler.java | 39 ++
.../org/apache/storm/sql/runtime/Channels.java | 80 ++++
.../apache/storm/sql/runtime/DataSource.java | 29 ++
.../storm/sql/runtime/DataSourcesProvider.java | 49 ++
.../storm/sql/runtime/DataSourcesRegistry.java | 78 +++
.../org/apache/storm/sql/runtime/FieldInfo.java | 45 ++
.../storm/sql/runtime/IOutputSerializer.java | 31 ++
.../sql/runtime/ISqlTridentDataSource.java | 30 ++
.../storm/sql/runtime/StormSqlFunctions.java | 36 ++
.../trident/AbstractTridentProcessor.java | 43 ++
.../test/org/apache/storm/sql/TestUtils.java | 163 +++++++
.../jvm/storm/kafka/ByteBufferSerializer.java | 41 ++
.../src/jvm/storm/kafka/IntSerializer.java | 42 ++
pom.xml | 17 +
.../src/clj/backtype/storm/daemon/drpc.clj | 6 +-
.../src/clj/backtype/storm/daemon/logviewer.clj | 6 +-
.../src/clj/backtype/storm/daemon/nimbus.clj | 8 +-
.../clj/backtype/storm/daemon/supervisor.clj | 8 +-
storm-core/src/clj/backtype/storm/ui/core.clj | 8 +-
.../org/apache/storm/pacemaker/pacemaker.clj | 8 +-
.../storm/pacemaker/pacemaker_state_factory.clj | 1 +
.../src/jvm/backtype/storm/utils/Utils.java | 15 +-
.../storm/windowing/WindowManagerTest.java | 22 +-
storm-dist/binary/pom.xml | 10 +
storm-dist/binary/src/main/assembly/binary.xml | 25 +-
71 files changed, 5116 insertions(+), 23 deletions(-)
----------------------------------------------------------------------