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 2015/12/09 02:14:20 UTC
[2/3] storm git commit: Merge branch 'master' into STORM-1374
Merge branch 'master' into STORM-1374
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/96ed62a3
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/96ed62a3
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/96ed62a3
Branch: refs/heads/master
Commit: 96ed62a34907566a67b354bba1f455e7cb96f868
Parents: 98c90f0 f33e9c9
Author: Jungtaek Lim <ka...@gmail.com>
Authored: Wed Dec 9 10:00:49 2015 +0900
Committer: Jungtaek Lim <ka...@gmail.com>
Committed: Wed Dec 9 10:00:49 2015 +0900
----------------------------------------------------------------------
CHANGELOG.md | 4 +
README.markdown | 3 +-
bin/storm.py | 16 +-
conf/defaults.yaml | 1 +
dev-tools/travis/travis-install.sh | 12 +-
dev-tools/travis/travis-script.sh | 21 +-
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 +
storm-core/src/jvm/backtype/storm/Config.java | 1 +
.../src/jvm/backtype/storm/task/ShellBolt.java | 13 +-
.../storm/utils/ShellBoltMessageQueue.java | 121 +++++
.../src/jvm/backtype/storm/utils/Utils.java | 15 +-
.../test/clj/backtype/storm/multilang_test.clj | 2 +-
.../storm/utils/ShellBoltMessageQueueTest.java | 85 ++++
storm-dist/binary/pom.xml | 10 +
storm-dist/binary/src/main/assembly/binary.xml | 25 +-
78 files changed, 5320 insertions(+), 51 deletions(-)
----------------------------------------------------------------------