Path	Lines of Code
DEVELOPER.md	284
README.markdown	48
RELEASING.md	197
SECURITY.md	385
THIRD-PARTY.properties	32
conf/storm_env.ini	25
dev-tools/checkstyle.xslt	22
dev-tools/docker/README.md	21
dev-tools/gitact/requirements.txt	12
examples/storm-hdfs-examples/pom.xml	83
examples/storm-hdfs-examples/src/main/java/org/apache/storm/hdfs/bolt/HdfsFileTopology.java	147
examples/storm-hdfs-examples/src/main/java/org/apache/storm/hdfs/bolt/SequenceFileTopology.java	149
examples/storm-hdfs-examples/src/main/java/org/apache/storm/hdfs/spout/HdfsSpoutTopology.java	139
examples/storm-hdfs-examples/src/main/java/org/apache/storm/hdfs/trident/FixedBatchSpout.java	67
examples/storm-hdfs-examples/src/main/java/org/apache/storm/hdfs/trident/TridentFileTopology.java	68
examples/storm-hdfs-examples/src/main/java/org/apache/storm/hdfs/trident/TridentSequenceTopology.java	67
examples/storm-jdbc-examples/pom.xml	75
examples/storm-jdbc-examples/src/main/java/org/apache/storm/jdbc/spout/UserSpout.java	62
examples/storm-jdbc-examples/src/main/java/org/apache/storm/jdbc/topology/AbstractUserTopology.java	82
examples/storm-jdbc-examples/src/main/java/org/apache/storm/jdbc/topology/UserPersistenceTopology.java	35
examples/storm-jdbc-examples/src/main/java/org/apache/storm/jdbc/topology/UserPersistenceTridentTopology.java	43
examples/storm-jms-examples/README.markdown	6
examples/storm-jms-examples/pom.xml	90
examples/storm-jms-examples/src/main/java/org/apache/storm/jms/example/ExampleJmsTopology.java	71
examples/storm-jms-examples/src/main/java/org/apache/storm/jms/example/GenericBolt.java	64
examples/storm-jms-examples/src/main/java/org/apache/storm/jms/example/JsonTupleProducer.java	24
examples/storm-jms-examples/src/main/java/org/apache/storm/jms/example/SpringJmsProvider.java	24
examples/storm-jms-examples/src/main/resources/jms-activemq.xml	12
examples/storm-jms-examples/src/main/resources/log4j.properties	23
examples/storm-kafka-client-examples/README.markdown	8
examples/storm-kafka-client-examples/pom.xml	92
examples/storm-kafka-client-examples/src/main/java/org/apache/storm/kafka/bolt/KafkaProducerTopology.java	35
examples/storm-kafka-client-examples/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutTestBolt.java	25
examples/storm-kafka-client-examples/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutTopologyMainNamedTopics.java	65
examples/storm-kafka-client-examples/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutTopologyMainWildcardTopics.java	34
examples/storm-kafka-client-examples/src/main/java/org/apache/storm/kafka/trident/TridentKafkaClientTopologyNamedTopics.java	63
examples/storm-kafka-client-examples/src/main/java/org/apache/storm/kafka/trident/TridentKafkaClientTopologyWildcardTopics.java	21
examples/storm-kafka-client-examples/src/main/java/org/apache/storm/kafka/trident/TridentKafkaConsumerTopology.java	17
examples/storm-kafka-client-examples/src/test/java/org/apache/storm/kafka/spout/KafkaSpoutTopologyMainNamedTopicsLocal.java	38
examples/storm-kafka-client-examples/src/test/java/org/apache/storm/kafka/spout/KafkaSpoutTopologyMainWildcardTopicsLocal.java	10
examples/storm-loadgen/README.md	164
examples/storm-loadgen/pom.xml	112
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/CaptureLoad.java	381
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/EstimateThroughput.java	71
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/ExecAndProcessLatencyEngine.java	67
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/GenLoad.java	286
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/GroupingType.java	59
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/HttpForwardingMetricsConsumer.java	45
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/HttpForwardingMetricsServer.java	80
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/InputStream.java	176
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/LoadBolt.java	64
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/LoadCompConf.java	160
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/LoadMetricsServer.java	901
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/LoadSpout.java	102
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/NormalDistStats.java	82
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/OutputStream.java	64
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/OutputStreamEngine.java	69
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/ScopedTopologySet.java	71
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/SlowExecutorPattern.java	40
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/ThroughputVsLatency.java	231
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/TopologyLoadConf.java	364
examples/storm-loadgen/src/test/java/org/apache/storm/loadgen/LoadCompConfTest.java	31
examples/storm-loadgen/src/test/java/org/apache/storm/loadgen/LoadMetricsServerTest.java	16
examples/storm-loadgen/src/test/java/org/apache/storm/loadgen/NormalDistStatsTest.java	20
examples/storm-loadgen/src/test/java/org/apache/storm/loadgen/OutputStreamTest.java	16
examples/storm-perf/README.markdown	34
examples/storm-perf/pom.xml	108
examples/storm-perf/src/main/conf/ConstSpoutIdBoltNullBoltTopo.yaml	4
examples/storm-perf/src/main/conf/ConstSpoutNullBoltTopo.yaml	4
examples/storm-perf/src/main/conf/FileReadWordCountTopo.yaml	5
examples/storm-perf/src/main/conf/HdfsSpoutNullBoltTopo.yaml	7
examples/storm-perf/src/main/conf/KafkaClientHdfsTopo.yaml	8
examples/storm-perf/src/main/conf/StrGenSpoutHdfsBoltTopo.yaml	6
examples/storm-perf/src/main/java/org/apache/storm/perf/BackPressureTopo.java	75
examples/storm-perf/src/main/java/org/apache/storm/perf/ConstSpoutIdBoltNullBoltTopo.java	56
examples/storm-perf/src/main/java/org/apache/storm/perf/ConstSpoutNullBoltTopo.java	59
examples/storm-perf/src/main/java/org/apache/storm/perf/ConstSpoutOnlyTopo.java	36
examples/storm-perf/src/main/java/org/apache/storm/perf/FileReadWordCountTopo.java	56
examples/storm-perf/src/main/java/org/apache/storm/perf/HdfsSpoutNullBoltTopo.java	61
examples/storm-perf/src/main/java/org/apache/storm/perf/KafkaClientHdfsTopo.java	100
examples/storm-perf/src/main/java/org/apache/storm/perf/KafkaClientSpoutNullBoltTopo.java	65
examples/storm-perf/src/main/java/org/apache/storm/perf/LowThroughputTopo.java	109
examples/storm-perf/src/main/java/org/apache/storm/perf/SimplifiedWordCountTopo.java	51
examples/storm-perf/src/main/java/org/apache/storm/perf/StrGenSpoutHdfsBoltTopo.java	90
examples/storm-perf/src/main/java/org/apache/storm/perf/ThroughputMeter.java	40
examples/storm-perf/src/main/java/org/apache/storm/perf/bolt/CountBolt.java	33
examples/storm-perf/src/main/java/org/apache/storm/perf/bolt/DevNullBolt.java	32
examples/storm-perf/src/main/java/org/apache/storm/perf/bolt/IdBolt.java	25
examples/storm-perf/src/main/java/org/apache/storm/perf/bolt/SplitSentenceBolt.java	31
examples/storm-perf/src/main/java/org/apache/storm/perf/queuetest/Acker.java	34
examples/storm-perf/src/main/java/org/apache/storm/perf/queuetest/AckingProducer.java	33
examples/storm-perf/src/main/java/org/apache/storm/perf/queuetest/Consumer.java	37
examples/storm-perf/src/main/java/org/apache/storm/perf/queuetest/Forwarder.java	44
examples/storm-perf/src/main/java/org/apache/storm/perf/queuetest/JCQueuePerfTest.java	92
examples/storm-perf/src/main/java/org/apache/storm/perf/queuetest/MyThread.java	14
examples/storm-perf/src/main/java/org/apache/storm/perf/queuetest/Producer.java	21
examples/storm-perf/src/main/java/org/apache/storm/perf/queuetest/Producer2.java	24
examples/storm-perf/src/main/java/org/apache/storm/perf/spout/ConstSpout.java	52
examples/storm-perf/src/main/java/org/apache/storm/perf/spout/FileReadSpout.java	104
examples/storm-perf/src/main/java/org/apache/storm/perf/spout/StringGenSpout.java	57
examples/storm-perf/src/main/java/org/apache/storm/perf/spout/WordGenSpout.java	79
examples/storm-perf/src/main/java/org/apache/storm/perf/toolstest/Cons.java	36
examples/storm-perf/src/main/java/org/apache/storm/perf/toolstest/JCToolsPerfTest.java	64
examples/storm-perf/src/main/java/org/apache/storm/perf/toolstest/MyThd.java	15
examples/storm-perf/src/main/java/org/apache/storm/perf/toolstest/Prod.java	22
examples/storm-perf/src/main/java/org/apache/storm/perf/toolstest/Prod2.java	20
examples/storm-perf/src/main/java/org/apache/storm/perf/utils/BasicMetricsCollector.java	214
examples/storm-perf/src/main/java/org/apache/storm/perf/utils/Helper.java	66
examples/storm-perf/src/main/java/org/apache/storm/perf/utils/IdentityBolt.java	22
examples/storm-perf/src/main/java/org/apache/storm/perf/utils/MetricsSample.java	160
examples/storm-redis-examples/pom.xml	79
examples/storm-redis-examples/src/main/java/org/apache/storm/redis/tools/Base64ToBinaryStateMigrationUtil.java	113
examples/storm-redis-examples/src/main/java/org/apache/storm/redis/topology/LookupWordCount.java	115
examples/storm-redis-examples/src/main/java/org/apache/storm/redis/topology/PersistentWordCount.java	67
examples/storm-redis-examples/src/main/java/org/apache/storm/redis/topology/WhitelistWordCount.java	108
examples/storm-redis-examples/src/main/java/org/apache/storm/redis/topology/WordCounter.java	40
examples/storm-redis-examples/src/main/java/org/apache/storm/redis/topology/WordSpout.java	58
examples/storm-redis-examples/src/main/java/org/apache/storm/redis/trident/PrintFunction.java	17
examples/storm-redis-examples/src/main/java/org/apache/storm/redis/trident/WordCountLookupMapper.java	33
examples/storm-redis-examples/src/main/java/org/apache/storm/redis/trident/WordCountStoreMapper.java	18
examples/storm-redis-examples/src/main/java/org/apache/storm/redis/trident/WordCountTridentRedis.java	58
examples/storm-redis-examples/src/main/java/org/apache/storm/redis/trident/WordCountTridentRedisCluster.java	64
examples/storm-redis-examples/src/main/java/org/apache/storm/redis/trident/WordCountTridentRedisClusterMap.java	59
examples/storm-redis-examples/src/main/java/org/apache/storm/redis/trident/WordCountTridentRedisMap.java	53
examples/storm-starter/README.markdown	80
examples/storm-starter/multilang/resources/asyncSplitsentence.js	20
examples/storm-starter/multilang/resources/randomsentence.js	60
examples/storm-starter/multilang/resources/splitsentence.js	18
examples/storm-starter/multilang/resources/splitsentence.py	7
examples/storm-starter/multilang/resources/splitsentence.rb	9
examples/storm-starter/pom.xml	201
examples/storm-starter/src/clj/org/apache/storm/starter/clj/bolts.clj	60
examples/storm-starter/src/clj/org/apache/storm/starter/clj/exclamation.clj	26
examples/storm-starter/src/clj/org/apache/storm/starter/clj/rolling_top_words.clj	34
examples/storm-starter/src/clj/org/apache/storm/starter/clj/word_count.clj	62
examples/storm-starter/src/jvm/org/apache/storm/starter/AnchoredWordCount.java	99
examples/storm-starter/src/jvm/org/apache/storm/starter/BasicDRPCTopology.java	50
examples/storm-starter/src/jvm/org/apache/storm/starter/BlobStoreAPIWordCountTopology.java	233
examples/storm-starter/src/jvm/org/apache/storm/starter/ExclamationTopology.java	47
examples/storm-starter/src/jvm/org/apache/storm/starter/FastWordCountTopology.java	150
examples/storm-starter/src/jvm/org/apache/storm/starter/InOrderDeliveryTest.java	132
examples/storm-starter/src/jvm/org/apache/storm/starter/JoinBoltExample.java	53
examples/storm-starter/src/jvm/org/apache/storm/starter/LambdaTopology.java	28
examples/storm-starter/src/jvm/org/apache/storm/starter/ManualDRPC.java	41
examples/storm-starter/src/jvm/org/apache/storm/starter/MultiThreadWordCountTopology.java	69
examples/storm-starter/src/jvm/org/apache/storm/starter/MultipleLoggerTopology.java	62
examples/storm-starter/src/jvm/org/apache/storm/starter/PersistentWindowingTopology.java	91
examples/storm-starter/src/jvm/org/apache/storm/starter/Prefix.java	12
examples/storm-starter/src/jvm/org/apache/storm/starter/ReachTopology.java	142
examples/storm-starter/src/jvm/org/apache/storm/starter/ResourceAwareExampleTopology.java	89
examples/storm-starter/src/jvm/org/apache/storm/starter/RollingTopWords.java	38
examples/storm-starter/src/jvm/org/apache/storm/starter/SingleJoinExample.java	39
examples/storm-starter/src/jvm/org/apache/storm/starter/SkewedRollingTopWords.java	40
examples/storm-starter/src/jvm/org/apache/storm/starter/SlidingTupleTsTopology.java	30
examples/storm-starter/src/jvm/org/apache/storm/starter/SlidingWindowTopology.java	63
examples/storm-starter/src/jvm/org/apache/storm/starter/StatefulTopology.java	79
examples/storm-starter/src/jvm/org/apache/storm/starter/StatefulWindowingTopology.java	65
examples/storm-starter/src/jvm/org/apache/storm/starter/WordCountTopology.java	47
examples/storm-starter/src/jvm/org/apache/storm/starter/WordCountTopologyNode.java	76
examples/storm-starter/src/jvm/org/apache/storm/starter/bolt/AbstractRankerBolt.java	67
examples/storm-starter/src/jvm/org/apache/storm/starter/bolt/IntermediateRankingsBolt.java	27
examples/storm-starter/src/jvm/org/apache/storm/starter/bolt/PrinterBolt.java	14
examples/storm-starter/src/jvm/org/apache/storm/starter/bolt/RollingCountAggBolt.java	42
examples/storm-starter/src/jvm/org/apache/storm/starter/bolt/RollingCountBolt.java	89
examples/storm-starter/src/jvm/org/apache/storm/starter/bolt/SingleJoinBolt.java	93
examples/storm-starter/src/jvm/org/apache/storm/starter/bolt/SlidingWindowSumBolt.java	40
examples/storm-starter/src/jvm/org/apache/storm/starter/bolt/TotalRankingsBolt.java	27
examples/storm-starter/src/jvm/org/apache/storm/starter/bolt/WordCountBolt.java	27
examples/storm-starter/src/jvm/org/apache/storm/starter/spout/RandomIntegerSpout.java	40
examples/storm-starter/src/jvm/org/apache/storm/starter/spout/RandomNumberGeneratorSpout.java	62
examples/storm-starter/src/jvm/org/apache/storm/starter/spout/RandomSentenceSpout.java	64
examples/storm-starter/src/jvm/org/apache/storm/starter/streams/AggregateExample.java	50
examples/storm-starter/src/jvm/org/apache/storm/starter/streams/BranchExample.java	30
examples/storm-starter/src/jvm/org/apache/storm/starter/streams/GroupByKeyAndWindowExample.java	63
examples/storm-starter/src/jvm/org/apache/storm/starter/streams/JoinExample.java	60
examples/storm-starter/src/jvm/org/apache/storm/starter/streams/StateQueryExample.java	54
examples/storm-starter/src/jvm/org/apache/storm/starter/streams/StatefulWordCount.java	31
examples/storm-starter/src/jvm/org/apache/storm/starter/streams/TypedTupleExample.java	27
examples/storm-starter/src/jvm/org/apache/storm/starter/streams/WindowedWordCount.java	29
examples/storm-starter/src/jvm/org/apache/storm/starter/streams/WordCountToBolt.java	52
examples/storm-starter/src/jvm/org/apache/storm/starter/tools/NthLastModifiedTimeTracker.java	45
examples/storm-starter/src/jvm/org/apache/storm/starter/tools/Rankable.java	6
examples/storm-starter/src/jvm/org/apache/storm/starter/tools/RankableObjectWithFields.java	90
examples/storm-starter/src/jvm/org/apache/storm/starter/tools/Rankings.java	94
examples/storm-starter/src/jvm/org/apache/storm/starter/tools/SlidingWindowCounter.java	38
examples/storm-starter/src/jvm/org/apache/storm/starter/tools/SlotBasedCounter.java	67
examples/storm-starter/src/jvm/org/apache/storm/starter/trident/DebugMemoryMapState.java	46
examples/storm-starter/src/jvm/org/apache/storm/starter/trident/TridentMapExample.java	91
examples/storm-starter/src/jvm/org/apache/storm/starter/trident/TridentMinMaxOfDevicesTopology.java	132
examples/storm-starter/src/jvm/org/apache/storm/starter/trident/TridentMinMaxOfVehiclesTopology.java	117
examples/storm-starter/src/jvm/org/apache/storm/starter/trident/TridentReach.java	118
examples/storm-starter/src/jvm/org/apache/storm/starter/trident/TridentWindowingInmemoryStoreTopology.java	50
examples/storm-starter/src/jvm/org/apache/storm/starter/trident/TridentWordCount.java	63
examples/storm-starter/test/clj/org/apache/storm/starter/clj/bolts_test.clj	81
examples/storm-starter/test/jvm/org/apache/storm/starter/bolt/IntermediateRankingsBoltTest.java	94
examples/storm-starter/test/jvm/org/apache/storm/starter/bolt/RollingCountBoltTest.java	68
examples/storm-starter/test/jvm/org/apache/storm/starter/bolt/TotalRankingsBoltTest.java	95
examples/storm-starter/test/jvm/org/apache/storm/starter/tools/NthLastModifiedTimeTrackerTest.java	80
examples/storm-starter/test/jvm/org/apache/storm/starter/tools/RankableObjectWithFieldsTest.java	193
examples/storm-starter/test/jvm/org/apache/storm/starter/tools/RankingsTest.java	292
examples/storm-starter/test/jvm/org/apache/storm/starter/tools/SlidingWindowCounterTest.java	64
examples/storm-starter/test/jvm/org/apache/storm/starter/tools/SlotBasedCounterTest.java	107
flux/README.md	685
flux/flux-core/src/main/resources/splash.txt	9
flux/flux-core/src/test/resources/configs/test.properties	18
flux/flux-examples/README.md	62
flux/flux-examples/src/main/java/org/apache/storm/flux/examples/OnlyValueRecordTranslator.java	16
flux/flux-examples/src/main/java/org/apache/storm/flux/examples/StatefulWordCounter.java	35
flux/flux-examples/src/main/java/org/apache/storm/flux/examples/TestPrintBolt.java	14
flux/flux-examples/src/main/java/org/apache/storm/flux/examples/TestWindowBolt.java	24
flux/flux-examples/src/main/java/org/apache/storm/flux/examples/WordCountClient.java	39
flux/flux-examples/src/main/java/org/apache/storm/flux/examples/WordCounter.java	32
flux/flux-examples/src/main/resources/hbase_bolt.properties	17
flux/flux-examples/src/main/resources/hdfs_bolt.properties	22
flux/flux-ui/README.md	2
integration-test/README.md	51
licenses/ASM BSD license.txt	25
licenses/Apache License 2.0.txt	169
licenses/CDDL 1.1.txt	294
licenses/JDOM Apache license 2.0.txt	43
licenses/Javalution BSD license.txt	27
licenses/argparse4j MIT License.txt	19
licenses/cc0 1.0.txt	109
licenses/janino BSD 3-clause.txt	27
licenses/jline BSD 3-clause.txt	27
licenses/jpam Apache License 2.0.txt	15
licenses/jsch revised BSD 3-clause.txt	24
licenses/paranamer BSD 3-clause.txt	25
licenses/sysout-over-slf4j MIT X11 License.txt	23
sql/README.md	21
storm-client/src/java_license_header.txt	17
storm-client/src/py_license_header.txt	17
storm-client/src/resources/storm-client-version-info.properties	24
storm-client/test/resources/ssl/README.md	8
storm-client/test/resources/storm-core-version-info.properties	22
storm-core/src/resources/storm-core-version-info.properties	24