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/21 05:06:52 UTC
[4/7] storm git commit: Merge remote-tracking branch
'upstream/master' into windowing-eventts
Merge remote-tracking branch 'upstream/master' into windowing-eventts
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/60ff46ea
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/60ff46ea
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/60ff46ea
Branch: refs/heads/master
Commit: 60ff46ea69bb170746f52e300f30ba931136513c
Parents: fa48383 ceb3a0c
Author: Arun Mahadevan <ai...@hortonworks.com>
Authored: Wed Dec 9 15:24:42 2015 +0530
Committer: Arun Mahadevan <ai...@hortonworks.com>
Committed: Wed Dec 9 15:24:42 2015 +0530
----------------------------------------------------------------------
.travis.yml | 13 +-
CHANGELOG.md | 23 +
LICENSE | 9 -
README.markdown | 9 +-
bin/storm | 2 +-
bin/storm.py | 78 +-
conf/defaults.yaml | 27 +-
dev-tools/travis/travis-install.sh | 12 +-
dev-tools/travis/travis-script.sh | 23 +-
docs/documentation/Pacemaker.md | 108 +
.../starter/ResourceAwareExampleTopology.java | 2 +-
.../src/jvm/storm/starter/RollingTopWords.java | 6 +-
.../storm/starter/SkewedRollingTopWords.java | 6 +-
.../starter/trident/TridentKafkaWordCount.java | 15 +-
external/flux/README.md | 3 +
.../java/org/apache/storm/flux/FluxBuilder.java | 48 +-
.../org/apache/storm/flux/model/ObjectDef.java | 2 +
.../org/apache/storm/flux/test/TestBolt.java | 4 +
.../resources/configs/config-methods-test.yaml | 1 +
external/flux/flux-examples/README.md | 9 +
.../storm/flux/examples/TestPrintBolt.java | 39 +
.../storm/flux/examples/TestWindowBolt.java | 47 +
.../src/main/resources/simple_windowing.yaml | 69 +
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 +
external/storm-cassandra/README.md | 202 +
external/storm-cassandra/pom.xml | 124 +
.../AbstractExecutionResultHandler.java | 60 +
.../cassandra/BaseExecutionResultHandler.java | 85 +
.../storm/cassandra/CassandraContext.java | 92 +
.../cassandra/DynamicStatementBuilder.java | 199 +
.../storm/cassandra/ExecutionResultHandler.java | 98 +
.../storm/cassandra/Murmur3StreamGrouping.java | 133 +
.../storm/cassandra/bolt/BaseCassandraBolt.java | 194 +
.../bolt/BatchCassandraWriterBolt.java | 201 +
.../cassandra/bolt/CassandraWriterBolt.java | 72 +
.../cassandra/bolt/GroupingBatchBuilder.java | 68 +
.../bolt/PairBatchStatementTuples.java | 52 +
.../cassandra/bolt/PairStatementTuple.java | 50 +
.../storm/cassandra/client/CassandraConf.java | 202 +
.../storm/cassandra/client/ClusterFactory.java | 73 +
.../storm/cassandra/client/SimpleClient.java | 42 +
.../cassandra/client/SimpleClientProvider.java | 35 +
.../cassandra/client/impl/DefaultClient.java | 123 +
.../cassandra/context/BaseBeanFactory.java | 65 +
.../storm/cassandra/context/BeanFactory.java | 48 +
.../storm/cassandra/context/WorkerCtx.java | 89 +
.../storm/cassandra/executor/AsyncExecutor.java | 153 +
.../executor/AsyncExecutorProvider.java | 40 +
.../cassandra/executor/AsyncResultHandler.java | 64 +
.../executor/ExecutionResultCollector.java | 99 +
.../executor/impl/BatchAsyncResultHandler.java | 73 +
.../executor/impl/SingleAsyncResultHandler.java | 72 +
.../query/BatchStatementTupleMapper.java | 57 +
.../cassandra/query/CQLClauseTupleMapper.java | 36 +
.../cassandra/query/CQLStatementBuilder.java | 31 +
.../query/CQLStatementTupleMapper.java | 86 +
.../cassandra/query/CQLTableTupleMapper.java | 39 +
.../cassandra/query/CQLValuesTupleMapper.java | 74 +
.../storm/cassandra/query/ContextQuery.java | 101 +
.../query/SimpleCQLStatementTupleMapper.java | 51 +
.../query/impl/BoundStatementMapperBuilder.java | 107 +
.../query/impl/InsertStatementBuilder.java | 153 +
.../query/impl/UpdateStatementBuilder.java | 118 +
.../cassandra/query/selector/FieldSelector.java | 68 +
.../cassandra/DynamicStatementBuilderTest.java | 133 +
.../apache/storm/cassandra/WeatherSpout.java | 84 +
.../storm/cassandra/bolt/BaseTopologyTest.java | 60 +
.../bolt/BatchCassandraWriterBoltTest.java | 63 +
.../cassandra/bolt/CassandraWriterBoltTest.java | 64 +
.../src/test/resources/schema.cql | 24 +
external/storm-hdfs/pom.xml | 70 +
.../storm/hdfs/blobstore/HdfsBlobStore.java | 384 +
.../storm/hdfs/blobstore/HdfsBlobStoreFile.java | 196 +
.../storm/hdfs/blobstore/HdfsBlobStoreImpl.java | 312 +
.../hdfs/blobstore/HdfsClientBlobStore.java | 120 +
.../ha/codedistributor/HDFSCodeDistributor.java | 118 -
.../storm/hdfs/blobstore/BlobStoreTest.java | 530 +
.../hdfs/blobstore/HdfsBlobStoreImplTest.java | 231 +
external/storm-kafka/README.md | 37 +-
.../jvm/storm/kafka/ByteBufferSerializer.java | 41 +
.../src/jvm/storm/kafka/IntSerializer.java | 42 +
.../src/jvm/storm/kafka/KafkaUtils.java | 8 +-
.../src/jvm/storm/kafka/KeyValueScheme.java | 5 +-
.../kafka/KeyValueSchemeAsMultiScheme.java | 5 +-
.../jvm/storm/kafka/MessageMetadataScheme.java | 6 +-
.../MessageMetadataSchemeAsMultiScheme.java | 3 +-
.../jvm/storm/kafka/StringKeyValueScheme.java | 3 +-
.../kafka/StringMessageAndMetadataScheme.java | 7 +-
.../storm/kafka/StringMultiSchemeWithTopic.java | 21 +-
.../src/jvm/storm/kafka/StringScheme.java | 20 +-
.../src/jvm/storm/kafka/bolt/KafkaBolt.java | 13 +-
.../storm/kafka/trident/TridentKafkaState.java | 10 +-
.../kafka/trident/TridentKafkaStateFactory.java | 10 +-
.../storm/kafka/StringKeyValueSchemeTest.java | 17 +-
.../src/test/storm/kafka/TestStringScheme.java | 40 +
.../src/test/storm/kafka/TestUtils.java | 8 +-
.../src/test/storm/kafka/TridentKafkaTest.java | 13 +-
.../test/storm/kafka/TridentKafkaTopology.java | 33 +-
.../test/storm/kafka/bolt/KafkaBoltTest.java | 6 +-
external/storm-metrics/pom.xml | 53 +-
.../resources/libsigar-amd64-freebsd-6.so | Bin 210641 -> 0 bytes
.../resources/resources/libsigar-amd64-linux.so | Bin 246605 -> 0 bytes
.../resources/libsigar-amd64-solaris.so | Bin 251360 -> 0 bytes
.../resources/libsigar-ia64-hpux-11.sl | Bin 577452 -> 0 bytes
.../resources/resources/libsigar-ia64-linux.so | Bin 494929 -> 0 bytes
.../resources/resources/libsigar-pa-hpux-11.sl | Bin 516096 -> 0 bytes
.../resources/resources/libsigar-ppc-aix-5.so | Bin 400925 -> 0 bytes
.../resources/resources/libsigar-ppc-linux.so | Bin 258547 -> 0 bytes
.../resources/resources/libsigar-ppc64-aix-5.so | Bin 425077 -> 0 bytes
.../resources/resources/libsigar-ppc64-linux.so | Bin 330767 -> 0 bytes
.../resources/resources/libsigar-s390x-linux.so | Bin 269932 -> 0 bytes
.../resources/libsigar-sparc-solaris.so | Bin 285004 -> 0 bytes
.../resources/libsigar-sparc64-solaris.so | Bin 261896 -> 0 bytes
.../resources/libsigar-universal-macosx.dylib | Bin 377668 -> 0 bytes
.../resources/libsigar-universal64-macosx.dylib | Bin 397440 -> 0 bytes
.../resources/libsigar-x86-freebsd-5.so | Bin 179751 -> 0 bytes
.../resources/libsigar-x86-freebsd-6.so | Bin 179379 -> 0 bytes
.../resources/resources/libsigar-x86-linux.so | Bin 233385 -> 0 bytes
.../resources/resources/libsigar-x86-solaris.so | Bin 242880 -> 0 bytes
.../resources/resources/sigar-amd64-winnt.dll | Bin 402432 -> 0 bytes
.../resources/resources/sigar-x86-winnt.dll | Bin 266240 -> 0 bytes
.../resources/resources/sigar-x86-winnt.lib | Bin 99584 -> 0 bytes
pom.xml | 58 +-
storm-core/pom.xml | 43 +-
storm-core/src/clj/backtype/storm/blobstore.clj | 28 +
storm-core/src/clj/backtype/storm/cluster.clj | 355 +-
.../cluster_state/zookeeper_state_factory.clj | 161 +
.../clj/backtype/storm/command/blobstore.clj | 162 +
.../clj/backtype/storm/command/heartbeats.clj | 52 +
storm-core/src/clj/backtype/storm/config.clj | 30 +-
.../src/clj/backtype/storm/daemon/common.clj | 30 +-
.../src/clj/backtype/storm/daemon/drpc.clj | 6 +-
.../src/clj/backtype/storm/daemon/logviewer.clj | 6 +-
.../src/clj/backtype/storm/daemon/nimbus.clj | 684 +-
.../clj/backtype/storm/daemon/supervisor.clj | 487 +-
.../src/clj/backtype/storm/daemon/worker.clj | 32 +-
storm-core/src/clj/backtype/storm/testing.clj | 5 +-
storm-core/src/clj/backtype/storm/ui/core.clj | 8 +-
storm-core/src/clj/backtype/storm/util.clj | 37 +-
storm-core/src/clj/backtype/storm/zookeeper.clj | 31 +-
.../org/apache/storm/pacemaker/pacemaker.clj | 241 +
.../storm/pacemaker/pacemaker_state_factory.clj | 125 +
storm-core/src/jvm/backtype/storm/Config.java | 195 +-
.../src/jvm/backtype/storm/StormSubmitter.java | 2 +
.../storm/blobstore/AtomicOutputStream.java | 32 +
.../storm/blobstore/BlobKeySequenceInfo.java | 40 +
.../jvm/backtype/storm/blobstore/BlobStore.java | 445 +
.../storm/blobstore/BlobStoreAclHandler.java | 399 +
.../backtype/storm/blobstore/BlobStoreFile.java | 50 +
.../storm/blobstore/BlobStoreUtils.java | 257 +
.../storm/blobstore/BlobSynchronizer.java | 124 +
.../storm/blobstore/ClientBlobStore.java | 184 +
.../storm/blobstore/FileBlobStoreImpl.java | 248 +
.../storm/blobstore/InputStreamWithMeta.java | 26 +
.../jvm/backtype/storm/blobstore/KeyFilter.java | 22 +
.../storm/blobstore/KeySequenceNumber.java | 229 +
.../storm/blobstore/LocalFsBlobStore.java | 323 +
.../storm/blobstore/LocalFsBlobStoreFile.java | 159 +
.../storm/blobstore/NimbusBlobStore.java | 420 +
.../backtype/storm/cluster/ClusterState.java | 217 +
.../storm/cluster/ClusterStateContext.java | 41 +
.../storm/cluster/ClusterStateFactory.java | 28 +
.../storm/cluster/ClusterStateListener.java | 22 +
.../backtype/storm/cluster/ConnectionState.java | 24 +
.../jvm/backtype/storm/cluster/DaemonType.java | 27 +
.../storm/codedistributor/ICodeDistributor.java | 73 -
.../LocalFileSystemCodeDistributor.java | 123 -
.../backtype/storm/generated/AccessControl.java | 627 +
.../storm/generated/AccessControlType.java | 62 +
.../backtype/storm/generated/Assignment.java | 244 +-
.../storm/generated/BeginDownloadResult.java | 608 +
.../jvm/backtype/storm/generated/BoltStats.java | 340 +-
.../storm/generated/ClusterSummary.java | 108 +-
.../storm/generated/ClusterWorkerHeartbeat.java | 52 +-
.../storm/generated/ComponentPageInfo.java | 220 +-
.../backtype/storm/generated/Credentials.java | 44 +-
.../backtype/storm/generated/ExecutorStats.java | 160 +-
.../generated/HBAuthorizationException.java | 406 +
.../storm/generated/HBExecutionException.java | 406 +
.../jvm/backtype/storm/generated/HBMessage.java | 636 +
.../backtype/storm/generated/HBMessageData.java | 640 +
.../jvm/backtype/storm/generated/HBNodes.java | 461 +
.../jvm/backtype/storm/generated/HBPulse.java | 522 +
.../jvm/backtype/storm/generated/HBRecords.java | 466 +
.../storm/generated/HBServerMessageType.java | 113 +
.../generated/KeyAlreadyExistsException.java | 406 +
.../storm/generated/KeyNotFoundException.java | 406 +
.../storm/generated/LSApprovedWorkers.java | 44 +-
.../generated/LSSupervisorAssignments.java | 48 +-
.../backtype/storm/generated/LSTopoHistory.java | 64 +-
.../storm/generated/LSTopoHistoryList.java | 36 +-
.../storm/generated/LSWorkerHeartbeat.java | 36 +-
.../storm/generated/ListBlobsResult.java | 556 +
.../storm/generated/LocalAssignment.java | 36 +-
.../storm/generated/LocalStateData.java | 48 +-
.../jvm/backtype/storm/generated/LogConfig.java | 48 +-
.../jvm/backtype/storm/generated/Nimbus.java | 26917 +++++++++++++----
.../jvm/backtype/storm/generated/NodeInfo.java | 32 +-
.../storm/generated/ReadableBlobMeta.java | 510 +
.../storm/generated/RebalanceOptions.java | 44 +-
.../storm/generated/SettableBlobMeta.java | 567 +
.../backtype/storm/generated/SpoutStats.java | 224 +-
.../jvm/backtype/storm/generated/StormBase.java | 92 +-
.../backtype/storm/generated/StormTopology.java | 251 +-
.../storm/generated/SupervisorInfo.java | 152 +-
.../storm/generated/SupervisorSummary.java | 44 +-
.../storm/generated/TopologyHistoryInfo.java | 32 +-
.../backtype/storm/generated/TopologyInfo.java | 164 +-
.../storm/generated/TopologyPageInfo.java | 96 +-
.../backtype/storm/generated/TopologyStats.java | 220 +-
.../backtype/storm/hooks/BaseWorkerHook.java | 51 +
.../jvm/backtype/storm/hooks/IWorkerHook.java | 44 +
.../backtype/storm/localizer/LocalResource.java | 44 +
.../storm/localizer/LocalizedResource.java | 130 +
.../LocalizedResourceRetentionSet.java | 140 +
.../storm/localizer/LocalizedResourceSet.java | 101 +
.../jvm/backtype/storm/localizer/Localizer.java | 695 +
.../storm/messaging/netty/ControlMessage.java | 17 +-
.../messaging/netty/INettySerializable.java | 26 +
.../netty/KerberosSaslClientHandler.java | 152 +
.../netty/KerberosSaslNettyClient.java | 203 +
.../netty/KerberosSaslNettyClientState.java | 31 +
.../netty/KerberosSaslNettyServer.java | 210 +
.../netty/KerberosSaslNettyServerState.java | 30 +
.../netty/KerberosSaslServerHandler.java | 133 +
.../storm/messaging/netty/MessageDecoder.java | 4 +-
.../netty/NettyRenameThreadFactory.java | 10 +-
.../netty/NettyUncaughtExceptionHandler.java | 35 +
.../storm/messaging/netty/SaslMessageToken.java | 37 +-
.../storm/messaging/netty/SaslNettyClient.java | 22 +-
.../storm/messaging/netty/SaslNettyServer.java | 244 +-
.../messaging/netty/SaslNettyServerState.java | 13 +-
.../messaging/netty/SaslStormServerHandler.java | 21 +-
.../storm/messaging/netty/SaslUtils.java | 1 +
.../backtype/storm/messaging/netty/Server.java | 50 +-
.../messaging/netty/StormServerHandler.java | 24 +-
.../metric/HttpForwardingMetricsConsumer.java | 11 +-
.../storm/metric/LoggingMetricsConsumer.java | 7 +-
.../jvm/backtype/storm/multilang/BoltMsg.java | 3 +-
.../jvm/backtype/storm/multilang/ShellMsg.java | 3 +-
.../jvm/backtype/storm/multilang/SpoutMsg.java | 3 +-
.../AbstractDNSToSwitchMapping.java | 7 +-
.../networktopography/DNSToSwitchMapping.java | 1 -
.../jvm/backtype/storm/scheduler/INimbus.java | 16 +-
.../backtype/storm/scheduler/IScheduler.java | 8 +-
.../resource/ResourceAwareScheduler.java | 2 +-
.../strategies/ResourceAwareStrategy.java | 2 +-
.../backtype/storm/security/auth/AuthUtils.java | 69 +
.../storm/security/auth/IAuthorizer.java | 6 +
.../storm/security/auth/NimbusPrincipal.java | 29 +
.../storm/security/auth/ReqContext.java | 9 +-
.../authorizer/SimpleWhitelistAuthorizer.java | 2 +-
.../serialization/BlowfishTupleSerializer.java | 4 +-
.../src/jvm/backtype/storm/spout/ISpout.java | 18 +-
.../storm/spout/ISpoutWaitStrategy.java | 2 +-
.../jvm/backtype/storm/spout/MultiScheme.java | 3 +-
.../backtype/storm/spout/RawMultiScheme.java | 3 +-
.../src/jvm/backtype/storm/spout/RawScheme.java | 9 +-
.../src/jvm/backtype/storm/spout/Scheme.java | 3 +-
.../storm/spout/SchemeAsMultiScheme.java | 3 +-
.../jvm/backtype/storm/spout/ShellSpout.java | 6 +-
.../storm/spout/SpoutOutputCollector.java | 8 +-
.../src/jvm/backtype/storm/task/IBolt.java | 28 +-
.../backtype/storm/task/OutputCollector.java | 18 +-
.../src/jvm/backtype/storm/task/ShellBolt.java | 31 +-
.../backtype/storm/task/TopologyContext.java | 35 +-
.../storm/testing/CompleteTopologyParam.java | 2 +-
.../testing/ForwardingMetricsConsumer.java | 5 +
.../backtype/storm/testing/MkClusterParam.java | 2 +-
.../backtype/storm/testing/MockedSources.java | 2 +-
.../src/jvm/backtype/storm/testing/TestJob.java | 4 +-
.../storm/topology/TopologyBuilder.java | 59 +-
.../storm/topology/base/BaseRichSpout.java | 4 -
.../src/jvm/backtype/storm/tuple/ITuple.java | 20 +-
.../backtype/storm/utils/BufferInputStream.java | 53 +
.../storm/utils/ShellBoltMessageQueue.java | 121 +
.../jvm/backtype/storm/utils/ShellUtils.java | 7 +
.../StormBoundedExponentialBackoffRetry.java | 5 +-
.../storm/utils/ThriftTopologyUtils.java | 36 +-
.../src/jvm/backtype/storm/utils/Utils.java | 543 +-
.../storm/validation/ConfigValidation.java | 30 +-
.../validation/ConfigValidationAnnotations.java | 13 +-
.../storm/pacemaker/IServerMessageHandler.java | 25 +
.../apache/storm/pacemaker/PacemakerClient.java | 255 +
.../storm/pacemaker/PacemakerClientHandler.java | 75 +
.../apache/storm/pacemaker/PacemakerServer.java | 163 +
.../storm/pacemaker/codec/ThriftDecoder.java | 76 +
.../storm/pacemaker/codec/ThriftEncoder.java | 110 +
.../pacemaker/codec/ThriftNettyClientCodec.java | 94 +
.../pacemaker/codec/ThriftNettyServerCodec.java | 99 +
.../src/jvm/storm/trident/operation/Filter.java | 1 -
.../jvm/storm/trident/state/map/CachedMap.java | 1 -
.../jvm/storm/trident/util/TridentUtils.java | 33 +-
storm-core/src/py/storm/Nimbus-remote | 98 +
storm-core/src/py/storm/Nimbus.py | 5991 +++-
storm-core/src/py/storm/ttypes.py | 4297 ++-
storm-core/src/storm.thrift | 129 +-
.../test/clj/backtype/storm/cluster_test.clj | 27 +-
.../test/clj/backtype/storm/multilang_test.clj | 2 +-
.../test/clj/backtype/storm/nimbus_test.clj | 43 +-
.../storm/security/auth/ReqContext_test.clj | 1 +
.../test/clj/backtype/storm/supervisor_test.clj | 18 +-
.../storm/pacemaker_state_factory_test.clj | 150 +
.../clj/org/apache/storm/pacemaker_test.clj | 242 +
.../jvm/backtype/storm/TestConfigValidate.java | 18 +
.../backtype/storm/blobstore/BlobStoreTest.java | 461 +
.../storm/blobstore/BlobSynchronizerTest.java | 137 +
.../storm/blobstore/ClientBlobStoreTest.java | 179 +
.../LocalizedResourceRetentionSetTest.java | 85 +
.../localizer/LocalizedResourceSetTest.java | 74 +
.../backtype/storm/localizer/LocalizerTest.java | 671 +
.../jvm/backtype/storm/localizer/localtest.zip | Bin 0 -> 6378 bytes
.../storm/localizer/localtestwithsymlink.jar | Bin 0 -> 6591 bytes
.../storm/localizer/localtestwithsymlink.tar | Bin 0 -> 24576 bytes
.../storm/localizer/localtestwithsymlink.tar.gz | Bin 0 -> 6106 bytes
.../storm/localizer/localtestwithsymlink.tgz | Bin 0 -> 6106 bytes
.../storm/topology/TopologyBuilderTest.java | 5 +
.../storm/utils/ShellBoltMessageQueueTest.java | 85 +
.../storm/utils/ThriftTopologyUtilsTest.java | 94 +
storm-dist/binary/LICENSE | 27 +
storm-dist/binary/pom.xml | 10 +
storm-dist/binary/src/main/assembly/binary.xml | 36 +-
375 files changed, 60503 insertions(+), 12482 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/60ff46ea/storm-core/src/jvm/backtype/storm/Config.java
----------------------------------------------------------------------