You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2017/04/06 17:33:40 UTC
[51/52] [partial] storm git commit: STORM-2441 Break down
'storm-core' to extract client (worker) artifacts
STORM-2441 Break down 'storm-core' to extract client (worker) artifacts
* break down 'storm-core' into multiple artifacts
* 'storm-client': topology and worker, play as client SDK
* 'storm-client-misc': client SDK misc which is not added due to dependency addition
* 'storm-server': LocalCluster and related daemons
* 'storm-core': Clojure things and unported daemons (webapp) and tests
* 'storm-webapp': DRPC HTTP server, Logviewer and UI will be placed here
* Supervisor will set classpath for worker to just ensure 'storm-client', not 'storm-core'
* addresse documentation
* apply the change to all modules's pom.xml
* add new modules into Travis build
* NOTE: we don't shade and relocate what we have been relocated
* we should discuss how to overcome dependency issue
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/4de339a8
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/4de339a8
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/4de339a8
Branch: refs/heads/master
Commit: 4de339a8cd74ac06211d5a8e4f56c2ea7f6ee951
Parents: c652d3f
Author: Jungtaek Lim <ka...@gmail.com>
Authored: Wed Mar 29 08:08:54 2017 +0900
Committer: Jungtaek Lim <ka...@gmail.com>
Committed: Thu Apr 6 09:24:43 2017 +0900
----------------------------------------------------------------------
.travis.yml | 4 +-
DEVELOPER.md | 2 +-
bin/storm.py | 5 +-
...Defining-a-non-jvm-language-dsl-for-storm.md | 2 +-
docs/Lifecycle-of-a-topology.md | 2 +-
docs/Maven.md | 2 +-
docs/Metrics.md | 26 +-
docs/Storm-Scheduler.md | 4 +-
docs/Stream-API.md | 2 +-
docs/Structure-of-the-codebase.md | 80 +-
docs/Trident-API-Overview.md | 2 +-
docs/Trident-spouts.md | 8 +-
docs/Trident-state.md | 8 +-
docs/Windowing.md | 2 +-
docs/storm-kinesis.md | 2 +-
examples/storm-elasticsearch-examples/pom.xml | 2 +-
examples/storm-hbase-examples/pom.xml | 2 +-
examples/storm-hdfs-examples/pom.xml | 2 +-
.../storm/hdfs/spout/HdfsSpoutTopology.java | 2 +-
examples/storm-hive-examples/pom.xml | 2 +-
examples/storm-jdbc-examples/pom.xml | 2 +-
examples/storm-jms-examples/pom.xml | 4 +-
examples/storm-kafka-client-examples/pom.xml | 2 +-
examples/storm-kafka-examples/pom.xml | 2 +-
.../storm/kafka/trident/DrpcResultsPrinter.java | 4 +-
examples/storm-mongodb-examples/pom.xml | 2 +-
.../storm/mongodb/topology/WordCounter.java | 2 -
examples/storm-mqtt-examples/pom.xml | 2 +-
examples/storm-opentsdb-examples/pom.xml | 2 +-
examples/storm-perf/pom.xml | 2 +-
.../org/apache/storm/perf/KafkaHdfsTopo.java | 3 +-
.../storm/perf/KafkaSpoutNullBoltTopo.java | 3 +-
.../storm/perf/utils/BasicMetricsCollector.java | 1 -
.../org/apache/storm/perf/utils/Helper.java | 5 +-
examples/storm-pmml-examples/pom.xml | 2 +-
examples/storm-redis-examples/pom.xml | 2 +-
.../storm/redis/topology/WordCounter.java | 2 -
examples/storm-solr-examples/pom.xml | 2 +-
examples/storm-starter/README.markdown | 2 +-
examples/storm-starter/pom.xml | 13 +-
.../apache/storm/starter/clj/exclamation.clj | 6 +-
.../storm/starter/clj/rolling_top_words.clj | 8 +-
.../starter/BlobStoreAPIWordCountTopology.java | 3 -
.../storm/starter/FastWordCountTopology.java | 3 +-
.../storm/starter/InOrderDeliveryTest.java | 4 +-
.../storm/starter/MultipleLoggerTopology.java | 1 -
.../apache/storm/starter/StatefulTopology.java | 143 +
.../starter/StatefulWindowingTopology.java | 111 +
.../storm/starter/ThroughputVsLatency.java | 10 +-
.../storm/starter/streams/AggregateExample.java | 8 -
.../src/jvm/storm/starter/StatefulTopology.java | 144 -
.../starter/StatefulWindowingTopology.java | 112 -
external/storm-cassandra/pom.xml | 9 +-
.../storm/cassandra/bolt/BaseCassandraBolt.java | 2 -
.../storm/cassandra/client/CassandraConf.java | 15 +-
external/storm-druid/pom.xml | 8 +-
external/storm-elasticsearch/pom.xml | 2 +-
external/storm-eventhubs/pom.xml | 9 +-
.../eventhubs/samples/AtMostOnceEventCount.java | 54 -
.../storm/eventhubs/samples/EventCount.java | 157 -
.../storm/eventhubs/samples/EventHubLoop.java | 52 -
.../samples/OpaqueTridentEventCount.java | 53 -
.../samples/TransactionalTridentEventCount.java | 81 -
.../eventhubs/samples/bolt/GlobalCountBolt.java | 88 -
.../samples/bolt/PartialCountBolt.java | 68 -
.../eventhubs/samples/AtMostOnceEventCount.java | 54 +
.../storm/eventhubs/samples/EventCount.java | 157 +
.../storm/eventhubs/samples/EventHubLoop.java | 52 +
.../samples/OpaqueTridentEventCount.java | 53 +
.../samples/TransactionalTridentEventCount.java | 81 +
.../eventhubs/samples/bolt/GlobalCountBolt.java | 88 +
.../samples/bolt/PartialCountBolt.java | 68 +
external/storm-hbase/pom.xml | 2 +-
external/storm-hdfs/pom.xml | 6 +-
.../storm/hdfs/blobstore/HdfsBlobStoreImpl.java | 4 +-
.../storm/hdfs/blobstore/BlobStoreTest.java | 6 -
external/storm-hive/pom.xml | 4 +-
external/storm-jdbc/pom.xml | 2 +-
external/storm-jms/pom.xml | 2 +-
.../org/apache/storm/jms/spout/JmsSpout.java | 2 +-
.../storm/jms/trident/TridentJmsSpout.java | 2 +-
external/storm-kafka-client/pom.xml | 9 +-
external/storm-kafka/pom.xml | 2 +-
.../storm/kafka/DynamicBrokersReader.java | 12 +-
.../src/jvm/org/apache/storm/kafka/ZkState.java | 10 +-
.../org/apache/storm/kafka/KafkaUtilsTest.java | 2 +-
.../test/org/apache/storm/kafka/TestUtils.java | 2 -
.../apache/storm/kafka/bolt/KafkaBoltTest.java | 2 +-
external/storm-kinesis/README.md | 2 +-
external/storm-kinesis/pom.xml | 2 +-
external/storm-metrics/pom.xml | 2 +-
external/storm-mongodb/pom.xml | 6 +-
external/storm-mqtt/pom.xml | 8 +-
external/storm-opentsdb/pom.xml | 2 +-
external/storm-pmml/pom.xml | 2 +-
external/storm-redis/pom.xml | 2 +-
external/storm-solr/pom.xml | 2 +-
flux/README.md | 22 +
.../apache/storm/flux/examples/WordCounter.java | 1 -
flux/pom.xml | 9 +-
integration-test/pom.xml | 2 +-
.../st/tests/window/SlidingWindowTest.java | 2 +-
.../apache/storm/st/wrapper/StormCluster.java | 2 +-
.../org/apache/storm/st/wrapper/TopoWrap.java | 2 +-
pom.xml | 5 +-
sql/storm-sql-core/pom.xml | 8 +-
sql/storm-sql-external/storm-sql-hdfs/pom.xml | 2 +-
sql/storm-sql-external/storm-sql-kafka/pom.xml | 2 +-
.../storm-sql-mongodb/pom.xml | 2 +-
sql/storm-sql-external/storm-sql-redis/pom.xml | 2 +-
sql/storm-sql-runtime/pom.xml | 2 +-
.../storm/sql/runtime/utils/SerdeUtils.java | 6 +-
storm-client-misc/pom.xml | 50 +
.../metric/HttpForwardingMetricsConsumer.java | 85 +
.../metric/HttpForwardingMetricsServer.java | 118 +
storm-client/pom.xml | 336 +
storm-client/src/genthrift.sh | 34 +
storm-client/src/java_license_header.txt | 17 +
.../src/jvm/org/apache/storm/Config.java | 1697 +
.../src/jvm/org/apache/storm/Constants.java | 60 +
.../org/apache/storm/ICredentialsListener.java | 32 +
.../src/jvm/org/apache/storm/ILocalCluster.java | 176 +
.../src/jvm/org/apache/storm/ILocalDRPC.java | 36 +
.../jvm/org/apache/storm/ISubmitterHook.java | 31 +
.../src/jvm/org/apache/storm/LogWriter.java | 83 +
.../jvm/org/apache/storm/StormSubmitter.java | 603 +
.../src/jvm/org/apache/storm/StormTimer.java | 242 +
.../src/jvm/org/apache/storm/Thrift.java | 350 +
.../storm/annotation/InterfaceStability.java | 54 +
.../storm/blobstore/AtomicOutputStream.java | 32 +
.../org/apache/storm/blobstore/BlobStore.java | 490 +
.../storm/blobstore/BlobStoreAclHandler.java | 409 +
.../apache/storm/blobstore/BlobStoreFile.java | 50 +
.../apache/storm/blobstore/ClientBlobStore.java | 201 +
.../storm/blobstore/InputStreamWithMeta.java | 26 +
.../org/apache/storm/blobstore/KeyFilter.java | 22 +
.../apache/storm/blobstore/NimbusBlobStore.java | 428 +
.../src/jvm/org/apache/storm/bolt/JoinBolt.java | 595 +
.../storm/callback/DefaultWatcherCallBack.java | 35 +
.../apache/storm/callback/WatcherCallBack.java | 24 +
.../storm/callback/ZKStateChangedCallback.java | 25 +
.../org/apache/storm/clojure/ClojureBolt.java | 120 +
.../org/apache/storm/clojure/ClojureSpout.java | 153 +
.../org/apache/storm/clojure/RichShellBolt.java | 51 +
.../apache/storm/clojure/RichShellSpout.java | 51 +
.../storm/cluster/ClusterStateContext.java | 41 +
.../storm/cluster/ClusterStateListener.java | 22 +
.../org/apache/storm/cluster/ClusterUtils.java | 244 +
.../apache/storm/cluster/ConnectionState.java | 24 +
.../org/apache/storm/cluster/DaemonType.java | 27 +
.../org/apache/storm/cluster/ExecutorBeat.java | 44 +
.../org/apache/storm/cluster/IStateStorage.java | 219 +
.../storm/cluster/IStormClusterState.java | 198 +
.../storm/cluster/PaceMakerStateStorage.java | 265 +
.../cluster/PaceMakerStateStorageFactory.java | 37 +
.../storm/cluster/StateStorageFactory.java | 28 +
.../storm/cluster/StormClusterStateImpl.java | 735 +
.../org/apache/storm/cluster/VersionedData.java | 36 +
.../apache/storm/cluster/ZKStateStorage.java | 252 +
.../storm/cluster/ZKStateStorageFactory.java | 36 +
.../storm/container/cgroup/CgroupCenter.java | 216 +
.../storm/container/cgroup/CgroupCommon.java | 270 +
.../container/cgroup/CgroupCommonOperation.java | 81 +
.../container/cgroup/CgroupCoreFactory.java | 72 +
.../storm/container/cgroup/CgroupOperation.java | 79 +
.../storm/container/cgroup/CgroupUtils.java | 118 +
.../apache/storm/container/cgroup/Device.java | 75 +
.../storm/container/cgroup/Hierarchy.java | 130 +
.../storm/container/cgroup/SubSystem.java | 81 +
.../storm/container/cgroup/SubSystemType.java | 36 +
.../storm/container/cgroup/SystemOperation.java | 76 +
.../storm/container/cgroup/core/BlkioCore.java | 213 +
.../storm/container/cgroup/core/CgroupCore.java | 26 +
.../storm/container/cgroup/core/CpuCore.java | 135 +
.../container/cgroup/core/CpuacctCore.java | 71 +
.../storm/container/cgroup/core/CpusetCore.java | 209 +
.../container/cgroup/core/DevicesCore.java | 189 +
.../container/cgroup/core/FreezerCore.java | 66 +
.../storm/container/cgroup/core/MemoryCore.java | 188 +
.../storm/container/cgroup/core/NetClsCore.java | 69 +
.../container/cgroup/core/NetPrioCore.java | 65 +
.../storm/coordination/BatchBoltExecutor.java | 109 +
.../coordination/BatchOutputCollector.java | 46 +
.../coordination/BatchOutputCollectorImpl.java | 53 +
.../coordination/BatchSubtopologyBuilder.java | 447 +
.../storm/coordination/CoordinatedBolt.java | 385 +
.../apache/storm/coordination/IBatchBolt.java | 30 +
.../src/jvm/org/apache/storm/daemon/Acker.java | 139 +
.../org/apache/storm/daemon/DaemonCommon.java | 22 +
.../org/apache/storm/daemon/GrouperFactory.java | 243 +
.../org/apache/storm/daemon/Shutdownable.java | 22 +
.../org/apache/storm/daemon/StormCommon.java | 594 +
.../src/jvm/org/apache/storm/daemon/Task.java | 247 +
.../daemon/metrics/BuiltinBoltMetrics.java | 78 +
.../storm/daemon/metrics/BuiltinMetrics.java | 33 +
.../daemon/metrics/BuiltinMetricsUtil.java | 81 +
.../daemon/metrics/BuiltinSpoutMetrics.java | 64 +
.../daemon/metrics/SpoutThrottlingMetrics.java | 57 +
.../storm/daemon/supervisor/AdvancedFSOps.java | 367 +
.../supervisor/ClientSupervisorUtils.java | 167 +
.../daemon/supervisor/ExitCodeCallback.java | 30 +
.../storm/daemon/supervisor/IAdvancedFSOps.java | 173 +
.../storm/daemon/worker/LogConfigManager.java | 156 +
.../org/apache/storm/daemon/worker/Worker.java | 459 +
.../apache/storm/daemon/worker/WorkerState.java | 690 +
.../dependency/DependencyBlobStoreUtils.java | 43 +
.../dependency/DependencyPropertiesParser.java | 61 +
.../storm/dependency/DependencyUploader.java | 167 +
.../dependency/FileNotAvailableException.java | 33 +
.../storm/drpc/DRPCInvocationsClient.java | 130 +
.../jvm/org/apache/storm/drpc/DRPCSpout.java | 287 +
.../jvm/org/apache/storm/drpc/JoinResult.java | 75 +
.../org/apache/storm/drpc/KeyedFairBolt.java | 93 +
.../storm/drpc/LinearDRPCInputDeclarer.java | 52 +
.../storm/drpc/LinearDRPCTopologyBuilder.java | 393 +
.../org/apache/storm/drpc/PrepareRequest.java | 60 +
.../org/apache/storm/drpc/ReturnResults.java | 138 +
.../jvm/org/apache/storm/executor/Executor.java | 583 +
.../apache/storm/executor/ExecutorShutdown.java | 114 +
.../apache/storm/executor/ExecutorTransfer.java | 88 +
.../apache/storm/executor/IRunningExecutor.java | 31 +
.../apache/storm/executor/LocalExecutor.java | 56 +
.../org/apache/storm/executor/TupleInfo.java | 90 +
.../storm/executor/bolt/BoltExecutor.java | 139 +
.../executor/bolt/BoltOutputCollectorImpl.java | 171 +
.../storm/executor/error/IReportError.java | 22 +
.../storm/executor/error/ReportError.java | 77 +
.../storm/executor/error/ReportErrorAndDie.java | 49 +
.../storm/executor/spout/SpoutExecutor.java | 259 +
.../spout/SpoutOutputCollectorImpl.java | 147 +
.../apache/storm/generated/AccessControl.java | 627 +
.../storm/generated/AccessControlType.java | 62 +
.../storm/generated/AlreadyAliveException.java | 406 +
.../org/apache/storm/generated/Assignment.java | 1159 +
.../storm/generated/AuthorizationException.java | 406 +
.../storm/generated/BeginDownloadResult.java | 608 +
.../jvm/org/apache/storm/generated/Bolt.java | 514 +
.../storm/generated/BoltAggregateStats.java | 704 +
.../org/apache/storm/generated/BoltStats.java | 1390 +
.../apache/storm/generated/ClusterSummary.java | 879 +
.../storm/generated/ClusterWorkerHeartbeat.java | 768 +
.../storm/generated/CommonAggregateStats.java | 1060 +
.../generated/ComponentAggregateStats.java | 752 +
.../apache/storm/generated/ComponentCommon.java | 852 +
.../apache/storm/generated/ComponentObject.java | 462 +
.../storm/generated/ComponentPageInfo.java | 2352 +
.../apache/storm/generated/ComponentType.java | 62 +
.../org/apache/storm/generated/Credentials.java | 458 +
.../storm/generated/DRPCExceptionType.java | 68 +
.../storm/generated/DRPCExecutionException.java | 528 +
.../org/apache/storm/generated/DRPCRequest.java | 507 +
.../apache/storm/generated/DebugOptions.java | 506 +
.../apache/storm/generated/DistributedRPC.java | 1328 +
.../generated/DistributedRPCInvocations.java | 3904 ++
.../org/apache/storm/generated/ErrorInfo.java | 714 +
.../storm/generated/ExecutorAggregateStats.java | 526 +
.../apache/storm/generated/ExecutorInfo.java | 499 +
.../storm/generated/ExecutorSpecificStats.java | 387 +
.../apache/storm/generated/ExecutorStats.java | 915 +
.../apache/storm/generated/ExecutorSummary.java | 922 +
.../apache/storm/generated/GetInfoOptions.java | 422 +
.../apache/storm/generated/GlobalStreamId.java | 507 +
.../org/apache/storm/generated/Grouping.java | 800 +
.../generated/HBAuthorizationException.java | 406 +
.../storm/generated/HBExecutionException.java | 406 +
.../org/apache/storm/generated/HBMessage.java | 636 +
.../apache/storm/generated/HBMessageData.java | 640 +
.../jvm/org/apache/storm/generated/HBNodes.java | 461 +
.../jvm/org/apache/storm/generated/HBPulse.java | 522 +
.../org/apache/storm/generated/HBRecords.java | 466 +
.../storm/generated/HBServerMessageType.java | 113 +
.../generated/InvalidTopologyException.java | 406 +
.../org/apache/storm/generated/JavaObject.java | 561 +
.../apache/storm/generated/JavaObjectArg.java | 631 +
.../generated/KeyAlreadyExistsException.java | 406 +
.../storm/generated/KeyNotFoundException.java | 406 +
.../org/apache/storm/generated/KillOptions.java | 407 +
.../storm/generated/LSApprovedWorkers.java | 458 +
.../generated/LSSupervisorAssignments.java | 471 +
.../apache/storm/generated/LSSupervisorId.java | 406 +
.../apache/storm/generated/LSTopoHistory.java | 805 +
.../storm/generated/LSTopoHistoryList.java | 460 +
.../storm/generated/LSWorkerHeartbeat.java | 755 +
.../apache/storm/generated/ListBlobsResult.java | 556 +
.../apache/storm/generated/LocalAssignment.java | 676 +
.../apache/storm/generated/LocalStateData.java | 471 +
.../org/apache/storm/generated/LogConfig.java | 475 +
.../org/apache/storm/generated/LogLevel.java | 836 +
.../apache/storm/generated/LogLevelAction.java | 65 +
.../jvm/org/apache/storm/generated/Nimbus.java | 47241 +++++++++++++++++
.../apache/storm/generated/NimbusSummary.java | 796 +
.../org/apache/storm/generated/NodeInfo.java | 556 +
.../storm/generated/NotAliveException.java | 406 +
.../org/apache/storm/generated/NullStruct.java | 300 +
.../apache/storm/generated/NumErrorsChoice.java | 65 +
.../apache/storm/generated/ProfileAction.java | 74 +
.../apache/storm/generated/ProfileRequest.java | 631 +
.../storm/generated/ReadableBlobMeta.java | 510 +
.../storm/generated/RebalanceOptions.java | 664 +
.../storm/generated/SettableBlobMeta.java | 567 +
.../apache/storm/generated/ShellComponent.java | 516 +
.../storm/generated/SpecificAggregateStats.java | 387 +
.../storm/generated/SpoutAggregateStats.java | 407 +
.../org/apache/storm/generated/SpoutSpec.java | 514 +
.../org/apache/storm/generated/SpoutStats.java | 917 +
.../apache/storm/generated/StateSpoutSpec.java | 514 +
.../org/apache/storm/generated/StormBase.java | 1382 +
.../apache/storm/generated/StormTopology.java | 1272 +
.../org/apache/storm/generated/StreamInfo.java | 554 +
.../apache/storm/generated/SubmitOptions.java | 533 +
.../apache/storm/generated/SupervisorInfo.java | 1446 +
.../storm/generated/SupervisorPageInfo.java | 624 +
.../storm/generated/SupervisorSummary.java | 1265 +
.../storm/generated/ThriftSerializedObject.java | 516 +
.../storm/generated/TopologyActionOptions.java | 387 +
.../storm/generated/TopologyHistoryInfo.java | 461 +
.../apache/storm/generated/TopologyInfo.java | 2144 +
.../storm/generated/TopologyInitialStatus.java | 62 +
.../storm/generated/TopologyPageInfo.java | 2757 +
.../apache/storm/generated/TopologyStats.java | 1094 +
.../apache/storm/generated/TopologyStatus.java | 68 +
.../apache/storm/generated/TopologySummary.java | 1901 +
.../apache/storm/generated/WorkerResources.java | 605 +
.../apache/storm/generated/WorkerSummary.java | 1880 +
.../storm/grouping/CustomStreamGrouping.java | 43 +
.../src/jvm/org/apache/storm/grouping/Load.java | 77 +
.../grouping/LoadAwareCustomStreamGrouping.java | 24 +
.../grouping/LoadAwareShuffleGrouping.java | 76 +
.../org/apache/storm/grouping/LoadMapping.java | 64 +
.../storm/grouping/PartialKeyGrouping.java | 106 +
.../apache/storm/grouping/ShuffleGrouping.java | 63 +
.../org/apache/storm/hooks/BaseTaskHook.java | 61 +
.../org/apache/storm/hooks/BaseWorkerHook.java | 51 +
.../jvm/org/apache/storm/hooks/ITaskHook.java | 38 +
.../jvm/org/apache/storm/hooks/IWorkerHook.java | 44 +
.../storm/hooks/SubmitterHookException.java | 41 +
.../apache/storm/hooks/info/BoltAckInfo.java | 40 +
.../storm/hooks/info/BoltExecuteInfo.java | 40 +
.../apache/storm/hooks/info/BoltFailInfo.java | 40 +
.../org/apache/storm/hooks/info/EmitInfo.java | 44 +
.../apache/storm/hooks/info/SpoutAckInfo.java | 39 +
.../apache/storm/hooks/info/SpoutFailInfo.java | 39 +
.../storm/messaging/ConnectionWithStatus.java | 49 +
.../DeserializingConnectionCallback.java | 60 +
.../org/apache/storm/messaging/IConnection.java | 63 +
.../storm/messaging/IConnectionCallback.java | 31 +
.../org/apache/storm/messaging/IContext.java | 59 +
.../org/apache/storm/messaging/TaskMessage.java | 53 +
.../storm/messaging/TransportFactory.java | 57 +
.../apache/storm/messaging/local/Context.java | 218 +
.../apache/storm/messaging/netty/Client.java | 612 +
.../apache/storm/messaging/netty/Context.java | 113 +
.../storm/messaging/netty/ControlMessage.java | 75 +
.../messaging/netty/INettySerializable.java | 26 +
.../storm/messaging/netty/ISaslClient.java | 28 +
.../storm/messaging/netty/ISaslServer.java | 26 +
.../apache/storm/messaging/netty/IServer.java | 26 +
.../netty/KerberosSaslClientHandler.java | 154 +
.../netty/KerberosSaslNettyClient.java | 202 +
.../netty/KerberosSaslNettyClientState.java | 31 +
.../netty/KerberosSaslNettyServer.java | 209 +
.../netty/KerberosSaslNettyServerState.java | 30 +
.../netty/KerberosSaslServerHandler.java | 133 +
.../org/apache/storm/messaging/netty/Login.java | 411 +
.../storm/messaging/netty/MessageBatch.java | 118 +
.../storm/messaging/netty/MessageBuffer.java | 58 +
.../storm/messaging/netty/MessageDecoder.java | 144 +
.../storm/messaging/netty/MessageEncoder.java | 43 +
.../netty/NettyRenameThreadFactory.java | 56 +
.../netty/NettyUncaughtExceptionHandler.java | 35 +
.../storm/messaging/netty/SaslMessageToken.java | 114 +
.../storm/messaging/netty/SaslNettyClient.java | 154 +
.../messaging/netty/SaslNettyClientState.java | 31 +
.../storm/messaging/netty/SaslNettyServer.java | 157 +
.../messaging/netty/SaslNettyServerState.java | 30 +
.../messaging/netty/SaslStormClientHandler.java | 158 +
.../netty/SaslStormServerAuthorizeHandler.java | 83 +
.../messaging/netty/SaslStormServerHandler.java | 153 +
.../apache/storm/messaging/netty/SaslUtils.java | 68 +
.../apache/storm/messaging/netty/Server.java | 274 +
.../messaging/netty/StormClientHandler.java | 90 +
.../netty/StormClientPipelineFactory.java | 56 +
.../messaging/netty/StormServerHandler.java | 74 +
.../netty/StormServerPipelineFactory.java | 57 +
.../apache/storm/metric/EventLoggerBolt.java | 67 +
.../storm/metric/FileBasedEventLogger.java | 122 +
.../org/apache/storm/metric/IEventLogger.java | 70 +
.../storm/metric/LoggingMetricsConsumer.java | 76 +
.../storm/metric/MetricsConsumerBolt.java | 146 +
.../jvm/org/apache/storm/metric/SystemBolt.java | 161 +
.../storm/metric/api/AssignableMetric.java | 34 +
.../apache/storm/metric/api/CombinedMetric.java | 38 +
.../apache/storm/metric/api/CountMetric.java | 39 +
.../org/apache/storm/metric/api/ICombiner.java | 23 +
.../org/apache/storm/metric/api/IMetric.java | 30 +
.../storm/metric/api/IMetricsConsumer.java | 80 +
.../org/apache/storm/metric/api/IReducer.java | 24 +
.../storm/metric/api/IStatefulObject.java | 22 +
.../apache/storm/metric/api/MeanReducer.java | 54 +
.../storm/metric/api/MultiCountMetric.java | 45 +
.../storm/metric/api/MultiReducedMetric.java | 50 +
.../apache/storm/metric/api/ReducedMetric.java | 38 +
.../apache/storm/metric/api/StateMetric.java | 31 +
.../metric/api/rpc/AssignableShellMetric.java | 30 +
.../metric/api/rpc/CombinedShellMetric.java | 31 +
.../storm/metric/api/rpc/CountShellMetric.java | 37 +
.../storm/metric/api/rpc/IShellMetric.java | 31 +
.../metric/api/rpc/ReducedShellMetric.java | 32 +
.../apache/storm/metric/cgroup/CGroupCpu.java | 70 +
.../storm/metric/cgroup/CGroupCpuGuarantee.java | 52 +
.../storm/metric/cgroup/CGroupMemoryLimit.java | 39 +
.../storm/metric/cgroup/CGroupMemoryUsage.java | 39 +
.../storm/metric/cgroup/CGroupMetricsBase.java | 114 +
.../storm/metric/filter/FilterByMetricName.java | 110 +
.../storm/metric/filter/MetricsFilter.java | 26 +
.../metric/internal/CountStatAndMetric.java | 211 +
.../metric/internal/LatencyStatAndMetric.java | 262 +
.../storm/metric/internal/MetricStatTimer.java | 27 +
.../internal/MultiCountStatAndMetric.java | 112 +
.../internal/MultiLatencyStatAndMetric.java | 109 +
.../storm/metric/internal/RateTracker.java | 139 +
.../storm/metric/util/DataPointExpander.java | 79 +
.../jvm/org/apache/storm/multilang/BoltMsg.java | 79 +
.../org/apache/storm/multilang/ISerializer.java | 82 +
.../apache/storm/multilang/JsonSerializer.java | 203 +
.../storm/multilang/NoOutputException.java | 40 +
.../org/apache/storm/multilang/ShellMsg.java | 184 +
.../org/apache/storm/multilang/SpoutMsg.java | 50 +
.../AbstractDNSToSwitchMapping.java | 96 +
.../networktopography/DNSToSwitchMapping.java | 49 +
.../DefaultRackDNSToSwitchMapping.java | 52 +
.../jvm/org/apache/storm/nimbus/NimbusInfo.java | 120 +
.../apache/storm/pacemaker/PacemakerClient.java | 274 +
.../storm/pacemaker/PacemakerClientHandler.java | 80 +
.../storm/pacemaker/PacemakerClientPool.java | 113 +
.../pacemaker/PacemakerConnectionException.java | 24 +
.../storm/pacemaker/codec/ThriftDecoder.java | 69 +
.../storm/pacemaker/codec/ThriftEncoder.java | 109 +
.../pacemaker/codec/ThriftNettyClientCodec.java | 97 +
.../jvm/org/apache/storm/scheduler/Cluster.java | 857 +
.../apache/storm/scheduler/ExecutorDetails.java | 54 +
.../jvm/org/apache/storm/scheduler/INimbus.java | 49 +
.../org/apache/storm/scheduler/IScheduler.java | 40 +
.../org/apache/storm/scheduler/ISupervisor.java | 45 +
.../storm/scheduler/SchedulerAssignment.java | 61 +
.../scheduler/SchedulerAssignmentImpl.java | 135 +
.../storm/scheduler/SupervisorDetails.java | 138 +
.../org/apache/storm/scheduler/Topologies.java | 87 +
.../apache/storm/scheduler/TopologyDetails.java | 517 +
.../org/apache/storm/scheduler/WorkerSlot.java | 81 +
.../storm/scheduler/resource/Component.java | 54 +
.../storm/scheduler/resource/RAS_Node.java | 529 +
.../storm/scheduler/resource/RAS_Nodes.java | 138 +
.../storm/scheduler/resource/ResourceUtils.java | 207 +
.../scheduler/resource/SchedulingResult.java | 116 +
.../scheduler/resource/SchedulingState.java | 56 +
.../scheduler/resource/SchedulingStatus.java | 40 +
.../apache/storm/scheduler/resource/User.java | 350 +
.../DefaultResourceAwareStrategy.java | 757 +
.../strategies/scheduling/IStrategy.java | 47 +
.../storm/security/INimbusCredentialPlugin.java | 47 +
.../auth/AbstractSaslClientCallbackHandler.java | 76 +
.../auth/AbstractSaslServerCallbackHandler.java | 94 +
.../apache/storm/security/auth/AuthUtils.java | 419 +
.../org/apache/storm/security/auth/AutoSSL.java | 161 +
.../auth/DefaultHttpCredentialsPlugin.java | 96 +
.../security/auth/DefaultPrincipalToLocal.java | 42 +
.../apache/storm/security/auth/IAuthorizer.java | 53 +
.../storm/security/auth/IAutoCredentials.java | 55 +
.../security/auth/ICredentialsRenewer.java | 40 +
.../auth/IGroupMappingServiceProvider.java | 42 +
.../security/auth/IHttpCredentialsPlugin.java | 48 +
.../storm/security/auth/IPrincipalToLocal.java | 41 +
.../storm/security/auth/ITransportPlugin.java | 57 +
.../security/auth/KerberosPrincipalToLocal.java | 45 +
.../storm/security/auth/NimbusPrincipal.java | 29 +
.../apache/storm/security/auth/ReqContext.java | 152 +
.../security/auth/SaslTransportPlugin.java | 180 +
.../security/auth/ShellBasedGroupsMapping.java | 99 +
.../security/auth/SimpleTransportPlugin.java | 163 +
.../security/auth/SingleUserPrincipal.java | 53 +
.../storm/security/auth/TBackoffConnect.java | 82 +
.../storm/security/auth/ThriftClient.java | 124 +
.../security/auth/ThriftConnectionType.java | 86 +
.../storm/security/auth/ThriftServer.java | 78 +
.../auth/authorizer/DRPCAuthorizerBase.java | 63 +
.../authorizer/DRPCSimpleACLAuthorizer.java | 177 +
.../auth/authorizer/DenyAuthorizer.java | 47 +
.../authorizer/ImpersonationAuthorizer.java | 172 +
.../auth/authorizer/NoopAuthorizer.java | 47 +
.../auth/authorizer/SimpleACLAuthorizer.java | 173 +
.../authorizer/SimpleWhitelistAuthorizer.java | 60 +
.../auth/digest/ClientCallbackHandler.java | 58 +
.../auth/digest/DigestSaslTransportPlugin.java | 68 +
.../auth/digest/ServerCallbackHandler.java | 85 +
.../storm/security/auth/kerberos/AutoTGT.java | 269 +
.../auth/kerberos/AutoTGTKrb5LoginModule.java | 112 +
.../kerberos/AutoTGTKrb5LoginModuleTest.java | 44 +
.../auth/kerberos/ClientCallbackHandler.java | 104 +
.../kerberos/KerberosSaslTransportPlugin.java | 262 +
.../security/auth/kerberos/NoOpTTrasport.java | 54 +
.../auth/kerberos/ServerCallbackHandler.java | 96 +
.../auth/kerberos/jaas_kerberos_cluster.conf | 49 +
.../auth/kerberos/jaas_kerberos_launcher.conf | 31 +
.../auth/plain/PlainClientCallbackHandler.java | 31 +
.../auth/plain/PlainSaslTransportPlugin.java | 71 +
.../auth/plain/PlainServerCallbackHandler.java | 55 +
.../security/auth/plain/SaslPlainServer.java | 158 +
.../serialization/BlowfishTupleSerializer.java | 92 +
.../storm/serialization/DefaultKryoFactory.java | 64 +
.../DefaultSerializationDelegate.java | 58 +
.../GzipBridgeSerializationDelegate.java | 65 +
.../GzipBridgeThriftSerializationDelegate.java | 64 +
.../GzipSerializationDelegate.java | 64 +
.../GzipThriftSerializationDelegate.java | 57 +
.../storm/serialization/IKryoDecorator.java | 23 +
.../storm/serialization/IKryoFactory.java | 40 +
.../storm/serialization/ITupleDeserializer.java | 24 +
.../storm/serialization/ITupleSerializer.java | 26 +
.../serialization/KryoTupleDeserializer.java | 56 +
.../serialization/KryoTupleSerializer.java | 60 +
.../serialization/KryoValuesDeserializer.java | 50 +
.../serialization/KryoValuesSerializer.java | 58 +
.../serialization/SerializableSerializer.java | 61 +
.../serialization/SerializationDelegate.java | 35 +
.../serialization/SerializationFactory.java | 241 +
.../ThriftSerializationDelegate.java | 52 +
.../types/ArrayListSerializer.java | 32 +
.../serialization/types/HashMapSerializer.java | 32 +
.../serialization/types/HashSetSerializer.java | 32 +
.../types/ListDelegateSerializer.java | 32 +
.../org/apache/storm/spout/CheckPointState.java | 172 +
.../org/apache/storm/spout/CheckpointSpout.java | 232 +
.../storm/spout/IMultiSchemableSpout.java | 23 +
.../org/apache/storm/spout/ISchemableSpout.java | 24 +
.../src/jvm/org/apache/storm/spout/ISpout.java | 105 +
.../storm/spout/ISpoutOutputCollector.java | 32 +
.../apache/storm/spout/ISpoutWaitStrategy.java | 34 +
.../jvm/org/apache/storm/spout/MultiScheme.java | 29 +
.../storm/spout/NothingEmptyEmitStrategy.java | 31 +
.../org/apache/storm/spout/RawMultiScheme.java | 38 +
.../jvm/org/apache/storm/spout/RawScheme.java | 36 +
.../src/jvm/org/apache/storm/spout/Scheme.java | 29 +
.../apache/storm/spout/SchemeAsMultiScheme.java | 42 +
.../jvm/org/apache/storm/spout/ShellSpout.java | 327 +
.../storm/spout/SleepSpoutWaitStrategy.java | 41 +
.../storm/spout/SpoutOutputCollector.java | 144 +
.../storm/state/DefaultStateSerializer.java | 77 +
.../jvm/org/apache/storm/state/IStateSpout.java | 29 +
.../storm/state/IStateSpoutOutputCollector.java | 22 +
.../apache/storm/state/ISubscribedState.java | 25 +
.../state/ISynchronizeOutputCollector.java | 24 +
.../storm/state/InMemoryKeyValueState.java | 126 +
.../state/InMemoryKeyValueStateProvider.java | 43 +
.../org/apache/storm/state/KeyValueState.java | 58 +
.../jvm/org/apache/storm/state/Serializer.java | 30 +
.../src/jvm/org/apache/storm/state/State.java | 55 +
.../org/apache/storm/state/StateFactory.java | 69 +
.../org/apache/storm/state/StateProvider.java | 38 +
.../storm/state/StateSpoutOutputCollector.java | 28 +
.../storm/state/SynchronizeOutputCollector.java | 30 +
.../apache/storm/stats/BoltExecutorStats.java | 106 +
.../jvm/org/apache/storm/stats/CommonStats.java | 114 +
.../apache/storm/stats/SpoutExecutorStats.java | 76 +
.../jvm/org/apache/storm/stats/StatsUtil.java | 2610 +
.../src/jvm/org/apache/storm/streams/Edge.java | 41 +
.../org/apache/storm/streams/GroupingInfo.java | 100 +
.../src/jvm/org/apache/storm/streams/Node.java | 170 +
.../src/jvm/org/apache/storm/streams/Pair.java | 103 +
.../org/apache/storm/streams/PairStream.java | 525 +
.../org/apache/storm/streams/PartitionNode.java | 37 +
.../org/apache/storm/streams/ProcessorBolt.java | 70 +
.../storm/streams/ProcessorBoltDelegate.java | 348 +
.../org/apache/storm/streams/ProcessorNode.java | 83 +
.../apache/storm/streams/RefCountedTuple.java | 64 +
.../jvm/org/apache/storm/streams/SinkNode.java | 44 +
.../jvm/org/apache/storm/streams/SpoutNode.java | 47 +
.../storm/streams/StatefulProcessorBolt.java | 116 +
.../jvm/org/apache/storm/streams/Stream.java | 515 +
.../org/apache/storm/streams/StreamBolt.java | 38 +
.../org/apache/storm/streams/StreamBuilder.java | 602 +
.../org/apache/storm/streams/StreamState.java | 43 +
.../org/apache/storm/streams/StreamUtil.java | 69 +
.../storm/streams/StreamsEdgeFactory.java | 29 +
.../org/apache/storm/streams/UniqueIdGen.java | 56 +
.../org/apache/storm/streams/WindowNode.java | 39 +
.../storm/streams/WindowedProcessorBolt.java | 137 +
.../storm/streams/operations/BiFunction.java | 37 +
.../streams/operations/CombinerAggregator.java | 97 +
.../storm/streams/operations/Consumer.java | 32 +
.../streams/operations/FlatMapFunction.java | 27 +
.../storm/streams/operations/Function.java | 34 +
.../streams/operations/IdentityFunction.java | 31 +
.../storm/streams/operations/Operation.java | 26 +
.../streams/operations/PairFlatMapFunction.java | 30 +
.../storm/streams/operations/PairFunction.java | 30 +
.../streams/operations/PairValueJoiner.java | 40 +
.../storm/streams/operations/Predicate.java | 33 +
.../storm/streams/operations/PrintConsumer.java | 30 +
.../storm/streams/operations/Reducer.java | 35 +
.../storm/streams/operations/StateUpdater.java | 67 +
.../storm/streams/operations/ValueJoiner.java | 36 +
.../streams/operations/aggregators/Count.java | 47 +
.../streams/operations/aggregators/LongSum.java | 45 +
.../operations/mappers/PairValueMapper.java | 51 +
.../operations/mappers/TupleValueMapper.java | 30 +
.../operations/mappers/TupleValueMappers.java | 174 +
.../streams/operations/mappers/ValueMapper.java | 45 +
.../operations/mappers/ValuesMapper.java | 48 +
.../processors/AggregateByKeyProcessor.java | 78 +
.../streams/processors/AggregateProcessor.java | 69 +
.../storm/streams/processors/BaseProcessor.java | 109 +
.../streams/processors/BatchProcessor.java | 25 +
.../streams/processors/BranchProcessor.java | 41 +
.../processors/ChainedProcessorContext.java | 66 +
.../processors/EmittingProcessorContext.java | 155 +
.../streams/processors/FilterProcessor.java | 35 +
.../streams/processors/FlatMapProcessor.java | 35 +
.../processors/FlatMapValuesProcessor.java | 36 +
.../streams/processors/ForEachProcessor.java | 33 +
.../processors/ForwardingProcessorContext.java | 102 +
.../storm/streams/processors/JoinProcessor.java | 152 +
.../storm/streams/processors/MapProcessor.java | 33 +
.../streams/processors/MapValuesProcessor.java | 34 +
.../MergeAggregateByKeyProcessor.java | 54 +
.../processors/MergeAggregateProcessor.java | 47 +
.../storm/streams/processors/PeekProcessor.java | 34 +
.../storm/streams/processors/Processor.java | 54 +
.../streams/processors/ProcessorContext.java | 62 +
.../processors/ReduceByKeyProcessor.java | 52 +
.../streams/processors/ReduceProcessor.java | 43 +
.../streams/processors/StateQueryProcessor.java | 48 +
.../streams/processors/StatefulProcessor.java | 36 +
.../processors/UpdateStateByKeyProcessor.java | 49 +
.../org/apache/storm/streams/tuple/Tuple10.java | 112 +
.../org/apache/storm/streams/tuple/Tuple3.java | 70 +
.../org/apache/storm/streams/tuple/Tuple4.java | 76 +
.../org/apache/storm/streams/tuple/Tuple5.java | 82 +
.../org/apache/storm/streams/tuple/Tuple6.java | 89 +
.../org/apache/storm/streams/tuple/Tuple7.java | 94 +
.../org/apache/storm/streams/tuple/Tuple8.java | 100 +
.../org/apache/storm/streams/tuple/Tuple9.java | 106 +
.../storm/streams/windowing/BaseWindow.java | 64 +
.../storm/streams/windowing/SlidingWindows.java | 151 +
.../streams/windowing/TumblingWindows.java | 119 +
.../apache/storm/streams/windowing/Window.java | 70 +
.../storm/task/GeneralTopologyContext.java | 202 +
.../src/jvm/org/apache/storm/task/IBolt.java | 84 +
.../org/apache/storm/task/IErrorReporter.java | 22 +
.../org/apache/storm/task/IMetricsContext.java | 31 +
.../org/apache/storm/task/IOutputCollector.java | 33 +
.../org/apache/storm/task/OutputCollector.java | 236 +
.../jvm/org/apache/storm/task/ShellBolt.java | 435 +
.../org/apache/storm/task/TopologyContext.java | 401 +
.../storm/task/WorkerTopologyContext.java | 106 +
.../apache/storm/testing/AckFailDelegate.java | 25 +
.../apache/storm/testing/AckFailMapTracker.java | 52 +
.../org/apache/storm/testing/AckTracker.java | 52 +
.../AlternateRackDNSToSwitchMapping.java | 65 +
.../apache/storm/testing/BatchNumberList.java | 72 +
.../apache/storm/testing/BatchProcessWord.java | 39 +
.../org/apache/storm/testing/BatchRepeatA.java | 48 +
.../org/apache/storm/testing/BoltTracker.java | 42 +
.../apache/storm/testing/CompletableSpout.java | 39 +
.../apache/storm/testing/CountingBatchBolt.java | 55 +
.../storm/testing/CountingCommitBolt.java | 57 +
.../org/apache/storm/testing/FeederSpout.java | 107 +
.../org/apache/storm/testing/FixedTuple.java | 43 +
.../apache/storm/testing/FixedTupleSpout.java | 185 +
.../testing/ForwardingMetricsConsumer.java | 100 +
.../org/apache/storm/testing/IdentityBolt.java | 42 +
.../apache/storm/testing/IntegrationTest.java | 38 +
.../storm/testing/KeyedCountingBatchBolt.java | 62 +
.../testing/KeyedCountingCommitterBolt.java | 24 +
.../storm/testing/KeyedSummingBatchBolt.java | 61 +
.../storm/testing/MemoryTransactionalSpout.java | 182 +
.../testing/MemoryTransactionalSpoutMeta.java | 38 +
.../apache/storm/testing/MkClusterParam.java | 69 +
.../org/apache/storm/testing/MkTupleParam.java | 58 +
.../org/apache/storm/testing/MockedSources.java | 68 +
.../jvm/org/apache/storm/testing/NGrouping.java | 48 +
.../storm/testing/NonRichBoltTracker.java | 51 +
.../testing/OpaqueMemoryTransactionalSpout.java | 188 +
.../apache/storm/testing/PrepareBatchBolt.java | 53 +
.../storm/testing/PythonShellMetricsBolt.java | 53 +
.../storm/testing/PythonShellMetricsSpout.java | 56 +
.../testing/SingleUserSimpleTransport.java | 37 +
.../org/apache/storm/testing/SpoutTracker.java | 111 +
.../storm/testing/TestAggregatesCounter.java | 63 +
.../org/apache/storm/testing/TestConfBolt.java | 62 +
.../apache/storm/testing/TestEventLogSpout.java | 143 +
.../storm/testing/TestEventOrderCheckBolt.java | 76 +
.../apache/storm/testing/TestGlobalCount.java | 60 +
.../apache/storm/testing/TestKryoDecorator.java | 31 +
.../apache/storm/testing/TestPlannerBolt.java | 45 +
.../apache/storm/testing/TestPlannerSpout.java | 86 +
.../org/apache/storm/testing/TestSerObject.java | 37 +
.../storm/testing/TestWordBytesCounter.java | 27 +
.../apache/storm/testing/TestWordCounter.java | 65 +
.../org/apache/storm/testing/TestWordSpout.java | 87 +
.../jvm/org/apache/storm/testing/TmpPath.java | 69 +
.../apache/storm/testing/TupleCaptureBolt.java | 83 +
.../topology/BaseConfigurationDeclarer.java | 83 +
.../topology/BaseStatefulBoltExecutor.java | 209 +
.../storm/topology/BasicBoltExecutor.java | 67 +
.../storm/topology/BasicOutputCollector.java | 72 +
.../org/apache/storm/topology/BoltDeclarer.java | 26 +
.../topology/CheckpointTupleForwarder.java | 103 +
.../ComponentConfigurationDeclarer.java | 29 +
.../apache/storm/topology/FailedException.java | 36 +
.../org/apache/storm/topology/IBasicBolt.java | 33 +
.../storm/topology/IBasicOutputCollector.java | 29 +
.../org/apache/storm/topology/IComponent.java | 44 +
.../org/apache/storm/topology/IRichBolt.java | 29 +
.../org/apache/storm/topology/IRichSpout.java | 29 +
.../apache/storm/topology/IRichStateSpout.java | 25 +
.../apache/storm/topology/IStatefulBolt.java | 48 +
.../storm/topology/IStatefulComponent.java | 56 +
.../storm/topology/IStatefulWindowedBolt.java | 26 +
.../apache/storm/topology/IWindowedBolt.java | 51 +
.../apache/storm/topology/InputDeclarer.java | 184 +
.../storm/topology/OutputFieldsDeclarer.java | 32 +
.../storm/topology/OutputFieldsGetter.java | 53 +
.../storm/topology/ReportedFailedException.java | 36 +
.../apache/storm/topology/ResourceDeclarer.java | 28 +
.../apache/storm/topology/SpoutDeclarer.java | 22 +
.../storm/topology/StatefulBoltExecutor.java | 193 +
.../topology/StatefulWindowedBoltExecutor.java | 372 +
.../apache/storm/topology/TopologyBuilder.java | 587 +
.../topology/TupleFieldTimestampExtractor.java | 48 +
.../storm/topology/WindowedBoltExecutor.java | 363 +
.../storm/topology/base/BaseBasicBolt.java | 33 +
.../storm/topology/base/BaseBatchBolt.java | 24 +
.../storm/topology/base/BaseComponent.java | 28 +
...BaseOpaquePartitionedTransactionalSpout.java | 25 +
.../base/BasePartitionedTransactionalSpout.java | 24 +
.../storm/topology/base/BaseRichBolt.java | 26 +
.../storm/topology/base/BaseRichSpout.java | 46 +
.../storm/topology/base/BaseStatefulBolt.java | 64 +
.../topology/base/BaseStatefulWindowedBolt.java | 168 +
.../base/BaseTickTupleAwareRichBolt.java | 60 +
.../topology/base/BaseTransactionalBolt.java | 24 +
.../topology/base/BaseTransactionalSpout.java | 24 +
.../storm/topology/base/BaseWindowedBolt.java | 365 +
.../apache/storm/transactional/ICommitter.java | 26 +
.../ICommitterTransactionalSpout.java | 31 +
.../transactional/ITransactionalSpout.java | 94 +
.../storm/transactional/TransactionAttempt.java | 61 +
.../TransactionalSpoutBatchExecutor.java | 96 +
.../TransactionalSpoutCoordinator.java | 214 +
.../TransactionalTopologyBuilder.java | 521 +
.../IOpaquePartitionedTransactionalSpout.java | 56 +
.../IPartitionedTransactionalSpout.java | 69 +
...uePartitionedTransactionalSpoutExecutor.java | 160 +
.../PartitionedTransactionalSpoutExecutor.java | 142 +
.../state/RotatingTransactionalState.java | 149 +
.../state/TestTransactionalState.java | 47 +
.../transactional/state/TransactionalState.java | 172 +
.../apache/storm/trident/JoinOutFieldsMode.java | 33 +
.../jvm/org/apache/storm/trident/JoinType.java | 30 +
.../jvm/org/apache/storm/trident/Stream.java | 897 +
.../org/apache/storm/trident/TridentState.java | 59 +
.../apache/storm/trident/TridentTopology.java | 986 +
.../trident/drpc/ReturnResultsReducer.java | 129 +
.../fluent/ChainedAggregatorDeclarer.java | 183 +
.../fluent/ChainedFullAggregatorDeclarer.java | 32 +
.../ChainedPartitionAggregatorDeclarer.java | 32 +
.../trident/fluent/GlobalAggregationScheme.java | 26 +
.../storm/trident/fluent/GroupedStream.java | 174 +
.../trident/fluent/IAggregatableStream.java | 31 +
.../fluent/IChainedAggregatorDeclarer.java | 24 +
.../storm/trident/fluent/UniqueIdGen.java | 38 +
.../storm/trident/graph/GraphGrouper.java | 119 +
.../org/apache/storm/trident/graph/Group.java | 150 +
.../storm/trident/operation/Aggregator.java | 26 +
.../storm/trident/operation/Assembly.java | 45 +
.../storm/trident/operation/BaseAggregator.java | 23 +
.../storm/trident/operation/BaseFilter.java | 23 +
.../storm/trident/operation/BaseFunction.java | 23 +
.../trident/operation/BaseMultiReducer.java | 33 +
.../storm/trident/operation/BaseOperation.java | 47 +
.../trident/operation/CombinerAggregator.java | 29 +
.../storm/trident/operation/Consumer.java | 35 +
.../operation/DefaultResourceDeclarer.java | 68 +
.../storm/trident/operation/EachOperation.java | 22 +
.../apache/storm/trident/operation/Filter.java | 48 +
.../trident/operation/FlatMapFunction.java | 37 +
.../storm/trident/operation/Function.java | 92 +
.../trident/operation/GroupedMultiReducer.java | 31 +
.../trident/operation/ITridentResource.java | 32 +
.../storm/trident/operation/MapFunction.java | 36 +
.../storm/trident/operation/MultiReducer.java | 31 +
.../storm/trident/operation/Operation.java | 46 +
.../OperationAwareFlatMapFunction.java | 24 +
.../operation/OperationAwareMapFunction.java | 24 +
.../trident/operation/ReducerAggregator.java | 26 +
.../trident/operation/TridentCollector.java | 52 +
.../operation/TridentMultiReducerContext.java | 36 +
.../operation/TridentOperationContext.java | 65 +
.../operation/builtin/ComparisonAggregator.java | 91 +
.../storm/trident/operation/builtin/Count.java | 41 +
.../storm/trident/operation/builtin/Debug.java | 62 +
.../storm/trident/operation/builtin/Equals.java | 38 +
.../trident/operation/builtin/FilterNull.java | 35 +
.../storm/trident/operation/builtin/FirstN.java | 130 +
.../storm/trident/operation/builtin/MapGet.java | 38 +
.../storm/trident/operation/builtin/Max.java | 37 +
.../operation/builtin/MaxWithComparator.java | 51 +
.../storm/trident/operation/builtin/Min.java | 36 +
.../operation/builtin/MinWithComparator.java | 51 +
.../storm/trident/operation/builtin/Negate.java | 76 +
.../trident/operation/builtin/SnapshotGet.java | 44 +
.../storm/trident/operation/builtin/Sum.java | 42 +
.../operation/builtin/TupleCollectionGet.java | 46 +
.../operation/impl/CaptureCollector.java | 42 +
.../operation/impl/ChainedAggregatorImpl.java | 113 +
.../trident/operation/impl/ChainedResult.java | 53 +
.../operation/impl/CombinerAggStateUpdater.java | 56 +
.../impl/CombinerAggregatorCombineImpl.java | 61 +
.../impl/CombinerAggregatorInitImpl.java | 49 +
.../operation/impl/ConsumerExecutor.java | 38 +
.../trident/operation/impl/FilterExecutor.java | 53 +
.../operation/impl/FlatMapFunctionExecutor.java | 64 +
.../operation/impl/GlobalBatchToPartition.java | 29 +
.../trident/operation/impl/GroupCollector.java | 48 +
.../operation/impl/GroupedAggregator.java | 96 +
.../impl/GroupedMultiReducerExecutor.java | 95 +
.../operation/impl/IdentityMultiReducer.java | 51 +
.../impl/IndexHashBatchToPartition.java | 29 +
.../storm/trident/operation/impl/JoinState.java | 39 +
.../operation/impl/JoinerMultiReducer.java | 142 +
.../operation/impl/MapFunctionExecutor.java | 62 +
...PreservingFieldsOrderJoinerMultiReducer.java | 175 +
.../operation/impl/ReducerAggStateUpdater.java | 53 +
.../operation/impl/ReducerAggregatorImpl.java | 56 +
.../storm/trident/operation/impl/Result.java | 27 +
.../operation/impl/SingleEmitAggregator.java | 95 +
.../trident/operation/impl/TrueFilter.java | 40 +
.../storm/trident/partition/GlobalGrouping.java | 42 +
.../trident/partition/IdentityGrouping.java | 59 +
.../trident/partition/IndexHashGrouping.java | 55 +
.../storm/trident/planner/BridgeReceiver.java | 38 +
.../org/apache/storm/trident/planner/Node.java | 69 +
.../storm/trident/planner/NodeStateInfo.java | 31 +
.../storm/trident/planner/PartitionNode.java | 50 +
.../storm/trident/planner/ProcessorContext.java | 29 +
.../storm/trident/planner/ProcessorNode.java | 38 +
.../apache/storm/trident/planner/SpoutNode.java | 39 +
.../storm/trident/planner/SubtopologyBolt.java | 246 +
.../storm/trident/planner/TridentProcessor.java | 40 +
.../storm/trident/planner/TupleReceiver.java | 27 +
.../planner/processor/AggregateProcessor.java | 84 +
.../planner/processor/AppendCollector.java | 62 +
.../planner/processor/EachProcessor.java | 80 +
.../planner/processor/FreshCollector.java | 59 +
.../trident/planner/processor/MapProcessor.java | 87 +
.../processor/MultiReducerProcessor.java | 93 +
.../processor/PartitionPersistProcessor.java | 107 +
.../planner/processor/ProjectedProcessor.java | 73 +
.../planner/processor/StateQueryProcessor.java | 107 +
.../planner/processor/TridentContext.java | 76 +
.../storm/trident/spout/BatchSpoutExecutor.java | 92 +
.../apache/storm/trident/spout/IBatchID.java | 24 +
.../apache/storm/trident/spout/IBatchSpout.java | 33 +
.../trident/spout/ICommitterTridentSpout.java | 31 +
.../spout/IOpaquePartitionedTridentSpout.java | 87 +
.../trident/spout/IPartitionedTridentSpout.java | 77 +
.../storm/trident/spout/ISpoutPartition.java | 25 +
.../storm/trident/spout/ITridentDataSource.java | 26 +
.../storm/trident/spout/ITridentSpout.java | 125 +
.../OpaquePartitionedTridentSpoutExecutor.java | 234 +
.../spout/PartitionedTridentSpoutExecutor.java | 188 +
.../trident/spout/RichSpoutBatchExecutor.java | 204 +
.../storm/trident/spout/RichSpoutBatchId.java | 49 +
.../spout/RichSpoutBatchIdSerializer.java | 38 +
.../trident/spout/RichSpoutBatchTriggerer.java | 183 +
.../trident/spout/TridentSpoutCoordinator.java | 94 +
.../trident/spout/TridentSpoutExecutor.java | 138 +
.../storm/trident/state/BaseQueryFunction.java | 25 +
.../storm/trident/state/BaseStateUpdater.java | 25 +
.../trident/state/CombinerValueUpdater.java | 45 +
.../storm/trident/state/ITupleCollection.java | 26 +
.../state/JSONNonTransactionalSerializer.java | 45 +
.../trident/state/JSONOpaqueSerializer.java | 52 +
.../state/JSONTransactionalSerializer.java | 50 +
.../apache/storm/trident/state/OpaqueValue.java | 75 +
.../storm/trident/state/QueryFunction.java | 28 +
.../storm/trident/state/ReadOnlyState.java | 31 +
.../trident/state/ReducerValueUpdater.java | 41 +
.../apache/storm/trident/state/Serializer.java | 26 +
.../org/apache/storm/trident/state/State.java | 39 +
.../storm/trident/state/StateFactory.java | 26 +
.../apache/storm/trident/state/StateSpec.java | 30 +
.../apache/storm/trident/state/StateType.java | 25 +
.../storm/trident/state/StateUpdater.java | 33 +
.../storm/trident/state/TransactionalValue.java | 44 +
.../storm/trident/state/ValueUpdater.java | 23 +
.../trident/state/map/CachedBatchReadsMap.java | 80 +
.../storm/trident/state/map/CachedMap.java | 78 +
.../storm/trident/state/map/IBackingMap.java | 26 +
.../state/map/MapCombinerAggStateUpdater.java | 84 +
.../state/map/MapReducerAggStateUpdater.java | 91 +
.../storm/trident/state/map/MapState.java | 26 +
.../state/map/MicroBatchIBackingMap.java | 85 +
.../trident/state/map/NonTransactionalMap.java | 67 +
.../storm/trident/state/map/OpaqueMap.java | 124 +
.../trident/state/map/ReadOnlyMapState.java | 26 +
.../trident/state/map/RemovableMapState.java | 25 +
.../trident/state/map/SnapshottableMap.java | 76 +
.../trident/state/map/TransactionalMap.java | 109 +
.../state/snapshot/ReadOnlySnapshottable.java | 24 +
.../trident/state/snapshot/Snapshottable.java | 27 +
.../trident/testing/CountAsAggregator.java | 47 +
.../storm/trident/testing/FeederBatchSpout.java | 185 +
.../testing/FeederCommitterBatchSpout.java | 96 +
.../storm/trident/testing/FixedBatchSpout.java | 97 +
.../apache/storm/trident/testing/IFeeder.java | 23 +
.../trident/testing/LRUMemoryMapState.java | 154 +
.../storm/trident/testing/MemoryBackingMap.java | 47 +
.../storm/trident/testing/MemoryMapState.java | 176 +
.../org/apache/storm/trident/testing/Split.java | 36 +
.../storm/trident/testing/StringLength.java | 32 +
.../storm/trident/testing/TrueFilter.java | 30 +
.../storm/trident/testing/TuplifyArgs.java | 41 +
.../storm/trident/topology/BatchInfo.java | 33 +
.../trident/topology/ITridentBatchBolt.java | 32 +
.../topology/MasterBatchCoordinator.java | 316 +
.../trident/topology/TransactionAttempt.java | 66 +
.../trident/topology/TridentBoltExecutor.java | 440 +
.../topology/TridentTopologyBuilder.java | 751 +
.../state/RotatingTransactionalState.java | 186 +
.../topology/state/TestTransactionalState.java | 47 +
.../topology/state/TransactionalState.java | 192 +
.../apache/storm/trident/tuple/ComboList.java | 92 +
.../apache/storm/trident/tuple/ConsList.java | 60 +
.../storm/trident/tuple/TridentTuple.java | 34 +
.../storm/trident/tuple/TridentTupleView.java | 361 +
.../storm/trident/tuple/ValuePointer.java | 60 +
.../storm/trident/util/ErrorEdgeFactory.java | 28 +
.../apache/storm/trident/util/IndexedEdge.java | 50 +
.../org/apache/storm/trident/util/LRUMap.java | 35 +
.../apache/storm/trident/util/TridentUtils.java | 115 +
.../windowing/AbstractTridentWindowManager.java | 238 +
.../windowing/ITridentWindowManager.java | 59 +
.../windowing/InMemoryTridentWindowManager.java | 72 +
.../trident/windowing/InMemoryWindowsStore.java | 200 +
.../windowing/InMemoryWindowsStoreFactory.java | 44 +
.../StoreBasedTridentWindowManager.java | 217 +
.../trident/windowing/TridentBatchTuple.java | 42 +
.../trident/windowing/WindowKryoSerializer.java | 87 +
.../windowing/WindowTridentProcessor.java | 265 +
.../storm/trident/windowing/WindowsState.java | 52 +
.../trident/windowing/WindowsStateFactory.java | 40 +
.../trident/windowing/WindowsStateUpdater.java | 81 +
.../storm/trident/windowing/WindowsStore.java | 79 +
.../trident/windowing/WindowsStoreFactory.java | 40 +
.../windowing/config/BaseWindowConfig.java | 48 +
.../windowing/config/SlidingCountWindow.java | 43 +
.../windowing/config/SlidingDurationWindow.java | 44 +
.../windowing/config/TumblingCountWindow.java | 43 +
.../config/TumblingDurationWindow.java | 42 +
.../trident/windowing/config/WindowConfig.java | 57 +
.../windowing/strategy/BaseWindowStrategy.java | 32 +
.../strategy/SlidingCountWindowStrategy.java | 59 +
.../strategy/SlidingDurationWindowStrategy.java | 60 +
.../strategy/TumblingCountWindowStrategy.java | 60 +
.../TumblingDurationWindowStrategy.java | 60 +
.../windowing/strategy/WindowStrategy.java | 45 +
.../org/apache/storm/tuple/AddressedTuple.java | 48 +
.../src/jvm/org/apache/storm/tuple/Fields.java | 142 +
.../src/jvm/org/apache/storm/tuple/ITuple.java | 214 +
.../jvm/org/apache/storm/tuple/MessageId.java | 93 +
.../src/jvm/org/apache/storm/tuple/Tuple.java | 68 +
.../jvm/org/apache/storm/tuple/TupleImpl.java | 356 +
.../src/jvm/org/apache/storm/tuple/Values.java | 37 +
.../jvm/org/apache/storm/utils/BatchHelper.java | 92 +
.../storm/utils/BufferFileInputStream.java | 54 +
.../apache/storm/utils/CRC32OutputStream.java | 44 +
.../jvm/org/apache/storm/utils/ConfigUtils.java | 365 +
.../org/apache/storm/utils/CuratorUtils.java | 115 +
.../jvm/org/apache/storm/utils/DRPCClient.java | 66 +
.../utils/DisruptorBackpressureCallback.java | 27 +
.../org/apache/storm/utils/DisruptorQueue.java | 589 +
.../storm/utils/ExtendedThreadPoolExecutor.java | 67 +
.../jvm/org/apache/storm/utils/IPredicate.java | 27 +
.../storm/utils/IndifferentAccessMap.java | 177 +
.../org/apache/storm/utils/InprocMessaging.java | 100 +
.../storm/utils/KeyedRoundRobinQueue.java | 68 +
.../org/apache/storm/utils/ListDelegate.java | 156 +
.../jvm/org/apache/storm/utils/LocalState.java | 277 +
.../jvm/org/apache/storm/utils/MutableInt.java | 43 +
.../jvm/org/apache/storm/utils/MutableLong.java | 43 +
.../org/apache/storm/utils/MutableObject.java | 38 +
.../org/apache/storm/utils/NimbusClient.java | 139 +
.../utils/NimbusLeaderNotFoundException.java | 41 +
.../org/apache/storm/utils/ObjectReader.java | 119 +
.../org/apache/storm/utils/ReflectionUtils.java | 83 +
.../storm/utils/RegisteredGlobalState.java | 62 +
.../jvm/org/apache/storm/utils/RotatingMap.java | 128 +
.../org/apache/storm/utils/ServiceRegistry.java | 47 +
.../storm/utils/ShellBoltMessageQueue.java | 121 +
.../org/apache/storm/utils/ShellProcess.java | 215 +
.../jvm/org/apache/storm/utils/ShellUtils.java | 505 +
.../StormBoundedExponentialBackoffRetry.java | 79 +
.../apache/storm/utils/ThriftTopologyUtils.java | 70 +
.../src/jvm/org/apache/storm/utils/Time.java | 235 +
.../org/apache/storm/utils/TimeCacheMap.java | 125 +
.../org/apache/storm/utils/TransferDrainer.java | 140 +
.../jvm/org/apache/storm/utils/TupleUtils.java | 67 +
.../src/jvm/org/apache/storm/utils/Utils.java | 1273 +
.../jvm/org/apache/storm/utils/VersionInfo.java | 131 +
.../org/apache/storm/utils/VersionedStore.java | 188 +
.../storm/utils/WindowedTimeThrottler.java | 51 +
.../storm/utils/WorkerBackpressureCallback.java | 26 +
.../storm/utils/WorkerBackpressureThread.java | 80 +
.../org/apache/storm/utils/WritableUtils.java | 375 +
.../apache/storm/utils/ZookeeperAuthInfo.java | 53 +
.../storm/utils/ZookeeperServerCnxnFactory.java | 84 +
.../storm/validation/ConfigValidation.java | 716 +
.../validation/ConfigValidationAnnotations.java | 218 +
.../storm/validation/ConfigValidationUtils.java | 175 +
.../storm/windowing/CountEvictionPolicy.java | 81 +
.../storm/windowing/CountTriggerPolicy.java | 76 +
.../storm/windowing/DefaultEvictionContext.java | 53 +
.../jvm/org/apache/storm/windowing/Event.java | 49 +
.../org/apache/storm/windowing/EventImpl.java | 51 +
.../apache/storm/windowing/EvictionContext.java | 47 +
.../apache/storm/windowing/EvictionPolicy.java | 82 +
.../storm/windowing/TimeEvictionPolicy.java | 72 +
.../storm/windowing/TimeTriggerPolicy.java | 132 +
.../storm/windowing/TimestampExtractor.java | 35 +
.../apache/storm/windowing/TriggerHandler.java | 31 +
.../apache/storm/windowing/TriggerPolicy.java | 49 +
.../org/apache/storm/windowing/TupleWindow.java | 26 +
.../apache/storm/windowing/TupleWindowImpl.java | 93 +
.../apache/storm/windowing/WaterMarkEvent.java | 38 +
.../windowing/WaterMarkEventGenerator.java | 121 +
.../windowing/WatermarkCountEvictionPolicy.java | 68 +
.../windowing/WatermarkCountTriggerPolicy.java | 91 +
.../windowing/WatermarkTimeEvictionPolicy.java | 77 +
.../windowing/WatermarkTimeTriggerPolicy.java | 126 +
.../jvm/org/apache/storm/windowing/Window.java | 55 +
.../windowing/WindowLifecycleListener.java | 43 +
.../apache/storm/windowing/WindowManager.java | 289 +
.../apache/storm/zookeeper/ClientZookeeper.java | 345 +
.../apache/storm/zookeeper/ZkEventTypes.java | 43 +
.../apache/storm/zookeeper/ZkKeeperStates.java | 41 +
storm-client/src/py/__init__.py | 18 +
storm-client/src/py/storm/DistributedRPC-remote | 112 +
storm-client/src/py/storm/DistributedRPC.py | 311 +
.../py/storm/DistributedRPCInvocations-remote | 133 +
.../src/py/storm/DistributedRPCInvocations.py | 886 +
storm-client/src/py/storm/Nimbus-remote | 420 +
storm-client/src/py/storm/Nimbus.py | 9915 ++++
storm-client/src/py/storm/__init__.py | 19 +
storm-client/src/py/storm/constants.py | 29 +
storm-client/src/py/storm/ttypes.py | 11695 ++++
storm-client/src/py_license_header.txt | 18 +
.../storm-client-version-info.properties | 24 +
storm-client/src/storm.thrift | 775 +
.../storm/PaceMakerStateStorageFactoryTest.java | 153 +
.../org/apache/storm/TestConfigValidate.java | 726 +
.../storm/blobstore/ClientBlobStoreTest.java | 179 +
.../jvm/org/apache/storm/bolt/TestJoinBolt.java | 357 +
.../cluster/StormClusterStateImplTest.java | 116 +
.../daemon/worker/LogConfigManagerTest.java | 202 +
.../apache/storm/daemon/worker/WorkerTest.java | 39 +
.../DependencyPropertiesParserTest.java | 72 +
.../dependency/DependencyUploaderTest.java | 296 +
.../storm/executor/error/ReportErrorTest.java | 74 +
.../storm/grouping/PartialKeyGroupingTest.java | 66 +
.../storm/grouping/ShuffleGroupingTest.java | 147 +
.../metric/filter/FilterByMetricNameTest.java | 95 +
.../metric/internal/CountStatAndMetricTest.java | 86 +
.../internal/LatencyStatAndMetricTest.java | 83 +
.../storm/metric/internal/RateTrackerTest.java | 94 +
.../metric/util/DataPointExpanderTest.java | 109 +
.../storm/security/auth/AuthUtilsTest.java | 240 +
.../storm/security/auth/AuthUtilsTestMock.java | 82 +
.../apache/storm/security/auth/AutoSSLTest.java | 136 +
.../auth/DefaultHttpCredentialsPluginTest.java | 90 +
.../storm/security/auth/ReqContextTest.java | 87 +
.../security/auth/SaslTransportPluginTest.java | 49 +
.../storm/security/auth/ThriftClientTest.java | 68 +
.../storm/security/auth/ThriftServerTest.java | 38 +
.../authorizer/DRPCSimpleACLAuthorizerTest.java | 163 +
.../BlowfishTupleSerializerTest.java | 86 +
.../GzipBridgeSerializationDelegateTest.java | 82 +
...ipBridgeThriftSerializationDelegateTest.java | 71 +
.../serialization/SerializationFactoryTest.java | 61 +
.../ThriftBridgeSerializationDelegateTest.java | 60 +
.../apache/storm/spout/CheckpointSpoutTest.java | 262 +
.../storm/state/InMemoryKeyValueStateTest.java | 99 +
.../apache/storm/streams/ProcessorBoltTest.java | 174 +
.../streams/StatefulProcessorBoltTest.java | 111 +
.../apache/storm/streams/StreamBuilderTest.java | 268 +
.../streams/WindowedProcessorBoltTest.java | 110 +
.../streams/processors/JoinProcessorTest.java | 125 +
.../topology/StatefulBoltExecutorTest.java | 178 +
.../StatefulWindowedBoltExecutorTest.java | 131 +
.../storm/topology/TopologyBuilderTest.java | 118 +
.../topology/WindowedBoltExecutorTest.java | 230 +
.../storm/trident/TestTridentTopology.java | 76 +
.../storm/trident/TridentWindowingTest.java | 105 +
.../jvm/org/apache/storm/tuple/FieldsTest.java | 126 +
.../apache/storm/utils/CuratorUtilsTest.java | 108 +
.../utils/DisruptorQueueBackpressureTest.java | 110 +
.../apache/storm/utils/DisruptorQueueTest.java | 187 +
.../apache/storm/utils/MockTupleHelpers.java | 40 +
.../storm/utils/ShellBoltMessageQueueTest.java | 85 +
...StormBoundedExponentialBackoffRetryTest.java | 101 +
.../storm/utils/ThriftTopologyUtilsTest.java | 106 +
.../utils/ThrowableNestedCauseMatcher.java | 44 +
.../jvm/org/apache/storm/utils/TimeTest.java | 95 +
.../jvm/org/apache/storm/utils/UtilsTest.java | 141 +
.../utils/WorkerBackpressureThreadTest.java | 50 +
.../utils/ZookeeperServerCnxnFactoryTest.java | 39 +
.../windowing/WaterMarkEventGeneratorTest.java | 118 +
.../storm/windowing/WindowManagerTest.java | 570 +
.../drpc-simple-acl-test-scenario.yaml | 28 +
storm-clojure/pom.xml | 6 +
.../src/clj/org/apache/storm/testing.clj | 2 +-
.../src/clj/org/apache/storm/thrift.clj | 23 +-
storm-clojure/src/test/clj/clojure_test.clj | 40 +-
storm-core/pom.xml | 242 +-
.../apache/storm/command/shell_submission.clj | 4 +-
storm-core/src/clj/org/apache/storm/config.clj | 6 +-
.../clj/org/apache/storm/daemon/logviewer.clj | 68 +-
.../clj/org/apache/storm/internal/thrift.clj | 17 +-
storm-core/src/clj/org/apache/storm/ui/core.clj | 84 +-
storm-core/src/clj/org/apache/storm/util.clj | 34 +-
.../src/dev/drpc-simple-acl-test-scenario.yaml | 28 -
storm-core/src/genthrift.sh | 33 -
storm-core/src/java_license_header.txt | 17 -
storm-core/src/jvm/org/apache/storm/Config.java | 2593 -
.../src/jvm/org/apache/storm/Constants.java | 60 -
.../org/apache/storm/ICredentialsListener.java | 32 -
.../src/jvm/org/apache/storm/ILocalCluster.java | 202 -
.../src/jvm/org/apache/storm/ILocalDRPC.java | 36 -
.../jvm/org/apache/storm/ISubmitterHook.java | 31 -
.../src/jvm/org/apache/storm/LocalCluster.java | 834 -
.../src/jvm/org/apache/storm/LocalDRPC.java | 90 -
.../src/jvm/org/apache/storm/LogWriter.java | 83 -
.../jvm/org/apache/storm/ProcessSimulator.java | 97 -
.../jvm/org/apache/storm/StormSubmitter.java | 602 -
.../src/jvm/org/apache/storm/StormTimer.java | 245 -
.../src/jvm/org/apache/storm/Testing.java | 716 -
storm-core/src/jvm/org/apache/storm/Thrift.java | 351 -
.../storm/annotation/InterfaceStability.java | 54 -
.../storm/blobstore/AtomicOutputStream.java | 32 -
.../storm/blobstore/BlobKeySequenceInfo.java | 40 -
.../org/apache/storm/blobstore/BlobStore.java | 490 -
.../storm/blobstore/BlobStoreAclHandler.java | 409 -
.../apache/storm/blobstore/BlobStoreFile.java | 50 -
.../apache/storm/blobstore/BlobStoreUtils.java | 288 -
.../storm/blobstore/BlobSynchronizer.java | 131 -
.../apache/storm/blobstore/ClientBlobStore.java | 201 -
.../storm/blobstore/FileBlobStoreImpl.java | 268 -
.../storm/blobstore/InputStreamWithMeta.java | 26 -
.../org/apache/storm/blobstore/KeyFilter.java | 22 -
.../storm/blobstore/KeySequenceNumber.java | 238 -
.../storm/blobstore/LocalFsBlobStore.java | 350 -
.../storm/blobstore/LocalFsBlobStoreFile.java | 159 -
.../apache/storm/blobstore/NimbusBlobStore.java | 428 -
.../src/jvm/org/apache/storm/bolt/JoinBolt.java | 595 -
.../storm/callback/DefaultWatcherCallBack.java | 35 -
.../apache/storm/callback/WatcherCallBack.java | 24 -
.../storm/callback/ZKStateChangedCallback.java | 25 -
.../org/apache/storm/clojure/ClojureBolt.java | 119 -
.../org/apache/storm/clojure/ClojureSpout.java | 153 -
.../org/apache/storm/clojure/RichShellBolt.java | 51 -
.../apache/storm/clojure/RichShellSpout.java | 51 -
.../storm/cluster/ClusterStateContext.java | 41 -
.../storm/cluster/ClusterStateListener.java | 22 -
.../org/apache/storm/cluster/ClusterUtils.java | 244 -
.../apache/storm/cluster/ConnectionState.java | 24 -
.../org/apache/storm/cluster/DaemonType.java | 27 -
.../org/apache/storm/cluster/ExecutorBeat.java | 44 -
.../org/apache/storm/cluster/IStateStorage.java | 219 -
.../storm/cluster/IStormClusterState.java | 198 -
.../storm/cluster/PaceMakerStateStorage.java | 266 -
.../cluster/PaceMakerStateStorageFactory.java | 37 -
.../storm/cluster/StateStorageFactory.java | 28 -
.../storm/cluster/StormClusterStateImpl.java | 724 -
.../org/apache/storm/cluster/VersionedData.java | 36 -
.../apache/storm/cluster/ZKStateStorage.java | 252 -
.../storm/cluster/ZKStateStorageFactory.java | 36 -
.../org/apache/storm/command/AdminCommands.java | 14 +-
.../jvm/org/apache/storm/command/Blobstore.java | 4 +-
.../org/apache/storm/command/ConfigValue.java | 4 +-
.../org/apache/storm/command/DevZookeeper.java | 10 +-
.../jvm/org/apache/storm/command/GetErrors.java | 2 +-
.../org/apache/storm/command/HealthCheck.java | 102 +-
.../org/apache/storm/command/Heartbeats.java | 4 +-
.../org/apache/storm/command/KillWorkers.java | 4 +-
.../org/apache/storm/command/SetLogLevel.java | 2 +-
.../container/ResourceIsolationInterface.java | 76 -
.../storm/container/cgroup/CgroupCenter.java | 216 -
.../storm/container/cgroup/CgroupCommon.java | 270 -
.../container/cgroup/CgroupCommonOperation.java | 81 -
.../container/cgroup/CgroupCoreFactory.java | 72 -
.../storm/container/cgroup/CgroupManager.java | 223 -
.../storm/container/cgroup/CgroupOperation.java | 79 -
.../storm/container/cgroup/CgroupUtils.java | 118 -
.../apache/storm/container/cgroup/Device.java | 75 -
.../storm/container/cgroup/Hierarchy.java | 130 -
.../storm/container/cgroup/SubSystem.java | 81 -
.../storm/container/cgroup/SubSystemType.java | 36 -
.../storm/container/cgroup/SystemOperation.java | 76 -
.../storm/container/cgroup/core/BlkioCore.java | 213 -
.../storm/container/cgroup/core/CgroupCore.java | 26 -
.../storm/container/cgroup/core/CpuCore.java | 135 -
.../container/cgroup/core/CpuacctCore.java | 71 -
.../storm/container/cgroup/core/CpusetCore.java | 209 -
.../container/cgroup/core/DevicesCore.java | 189 -
.../container/cgroup/core/FreezerCore.java | 66 -
.../storm/container/cgroup/core/MemoryCore.java | 188 -
.../storm/container/cgroup/core/NetClsCore.java | 69 -
.../container/cgroup/core/NetPrioCore.java | 65 -
.../storm/coordination/BatchBoltExecutor.java | 108 -
.../coordination/BatchOutputCollector.java | 46 -
.../coordination/BatchOutputCollectorImpl.java | 53 -
.../coordination/BatchSubtopologyBuilder.java | 447 -
.../storm/coordination/CoordinatedBolt.java | 386 -
.../apache/storm/coordination/IBatchBolt.java | 30 -
.../src/jvm/org/apache/storm/daemon/Acker.java | 140 -
.../daemon/ClientJarTransformerRunner.java | 12 +-
.../org/apache/storm/daemon/DaemonCommon.java | 22 -
.../apache/storm/daemon/DirectoryCleaner.java | 3 -
.../org/apache/storm/daemon/GrouperFactory.java | 244 -
.../org/apache/storm/daemon/Shutdownable.java | 22 -
.../org/apache/storm/daemon/StormCommon.java | 596 -
.../src/jvm/org/apache/storm/daemon/Task.java | 247 -
.../daemon/drpc/BlockingOutstandingRequest.java | 67 -
.../jvm/org/apache/storm/daemon/drpc/DRPC.java | 215 -
.../apache/storm/daemon/drpc/DRPCThrift.java | 58 -
.../storm/daemon/drpc/OutstandingRequest.java | 58 -
.../storm/daemon/drpc/RequestFactory.java | 24 -
.../daemon/metrics/BuiltinBoltMetrics.java | 78 -
.../storm/daemon/metrics/BuiltinMetrics.java | 33 -
.../daemon/metrics/BuiltinMetricsUtil.java | 81 -
.../daemon/metrics/BuiltinSpoutMetrics.java | 64 -
.../storm/daemon/metrics/MetricsUtils.java | 108 -
.../daemon/metrics/SpoutThrottlingMetrics.java | 57 -
.../reporters/ConsolePreparableReporter.java | 76 -
.../reporters/CsvPreparableReporter.java | 80 -
.../reporters/JmxPreparableReporter.java | 70 -
.../metrics/reporters/PreparableReporter.java | 32 -
.../org/apache/storm/daemon/nimbus/Nimbus.java | 3805 --
.../storm/daemon/nimbus/TopologyActions.java | 31 -
.../storm/daemon/nimbus/TopologyResources.java | 63 -
.../daemon/nimbus/TopologyStateTransition.java | 27 -
.../storm/daemon/supervisor/AdvancedFSOps.java | 363 -
.../storm/daemon/supervisor/BasicContainer.java | 719 -
.../supervisor/BasicContainerLauncher.java | 62 -
.../storm/daemon/supervisor/Container.java | 565 -
.../daemon/supervisor/ContainerLauncher.java | 104 -
.../supervisor/ContainerRecoveryException.java | 29 -
.../DefaultUncaughtExceptionHandler.java | 31 -
.../supervisor/EventManagerPushCallback.java | 37 -
.../daemon/supervisor/ExitCodeCallback.java | 30 -
.../storm/daemon/supervisor/Killable.java | 50 -
.../storm/daemon/supervisor/LocalContainer.java | 94 -
.../supervisor/LocalContainerLauncher.java | 60 -
.../daemon/supervisor/ReadClusterState.java | 358 -
.../daemon/supervisor/RunAsUserContainer.java | 100 -
.../supervisor/RunAsUserContainerLauncher.java | 60 -
.../apache/storm/daemon/supervisor/Slot.java | 785 -
.../daemon/supervisor/StandaloneSupervisor.java | 91 -
.../storm/daemon/supervisor/Supervisor.java | 359 -
.../daemon/supervisor/SupervisorUtils.java | 321 -
.../apache/storm/daemon/supervisor/UniFunc.java | 22 -
.../supervisor/timer/SupervisorHealthCheck.java | 41 -
.../supervisor/timer/SupervisorHeartbeat.java | 87 -
.../daemon/supervisor/timer/UpdateBlobs.java | 105 -
.../storm/daemon/worker/LogConfigManager.java | 156 -
.../org/apache/storm/daemon/worker/Worker.java | 458 -
.../apache/storm/daemon/worker/WorkerState.java | 691 -
.../dependency/DependencyPropertiesParser.java | 61 -
.../storm/dependency/DependencyUploader.java | 168 -
.../dependency/FileNotAvailableException.java | 33 -
.../storm/drpc/DRPCInvocationsClient.java | 130 -
.../jvm/org/apache/storm/drpc/DRPCSpout.java | 286 -
.../jvm/org/apache/storm/drpc/JoinResult.java | 75 -
.../org/apache/storm/drpc/KeyedFairBolt.java | 93 -
.../storm/drpc/LinearDRPCInputDeclarer.java | 52 -
.../storm/drpc/LinearDRPCTopologyBuilder.java | 393 -
.../org/apache/storm/drpc/PrepareRequest.java | 59 -
.../org/apache/storm/drpc/ReturnResults.java | 137 -
.../org/apache/storm/event/EventManager.java | 24 -
.../org/apache/storm/event/EventManagerImp.java | 100 -
.../jvm/org/apache/storm/executor/Executor.java | 563 -
.../apache/storm/executor/ExecutorShutdown.java | 114 -
.../apache/storm/executor/ExecutorTransfer.java | 88 -
.../apache/storm/executor/IRunningExecutor.java | 31 -
.../apache/storm/executor/LocalExecutor.java | 56 -
.../org/apache/storm/executor/TupleInfo.java | 90 -
.../storm/executor/bolt/BoltExecutor.java | 139 -
.../executor/bolt/BoltOutputCollectorImpl.java | 171 -
.../storm/executor/error/IReportError.java | 22 -
.../storm/executor/error/ReportError.java | 76 -
.../storm/executor/error/ReportErrorAndDie.java | 49 -
.../storm/executor/spout/SpoutExecutor.java | 257 -
.../spout/SpoutOutputCollectorImpl.java | 147 -
.../apache/storm/generated/AccessControl.java | 627 -
.../storm/generated/AccessControlType.java | 62 -
.../storm/generated/AlreadyAliveException.java | 406 -
.../org/apache/storm/generated/Assignment.java | 1159 -
.../storm/generated/AuthorizationException.java | 406 -
.../storm/generated/BeginDownloadResult.java | 608 -
.../jvm/org/apache/storm/generated/Bolt.java | 514 -
.../storm/generated/BoltAggregateStats.java | 704 -
.../org/apache/storm/generated/BoltStats.java | 1390 -
.../apache/storm/generated/ClusterSummary.java | 879 -
.../storm/generated/ClusterWorkerHeartbeat.java | 768 -
.../storm/generated/CommonAggregateStats.java | 1060 -
.../generated/ComponentAggregateStats.java | 752 -
.../apache/storm/generated/ComponentCommon.java | 852 -
.../apache/storm/generated/ComponentObject.java | 462 -
.../storm/generated/ComponentPageInfo.java | 2352 -
.../apache/storm/generated/ComponentType.java | 62 -
.../org/apache/storm/generated/Credentials.java | 458 -
.../storm/generated/DRPCExceptionType.java | 68 -
.../storm/generated/DRPCExecutionException.java | 528 -
.../org/apache/storm/generated/DRPCRequest.java | 507 -
.../apache/storm/generated/DebugOptions.java | 506 -
.../apache/storm/generated/DistributedRPC.java | 1328 -
.../generated/DistributedRPCInvocations.java | 3904 --
.../org/apache/storm/generated/ErrorInfo.java | 714 -
.../storm/generated/ExecutorAggregateStats.java | 526 -
.../apache/storm/generated/ExecutorInfo.java | 499 -
.../storm/generated/ExecutorSpecificStats.java | 387 -
.../apache/storm/generated/ExecutorStats.java | 915 -
.../apache/storm/generated/ExecutorSummary.java | 922 -
.../apache/storm/generated/GetInfoOptions.java | 422 -
.../apache/storm/generated/GlobalStreamId.java | 507 -
.../org/apache/storm/generated/Grouping.java | 800 -
.../generated/HBAuthorizationException.java | 406 -
.../storm/generated/HBExecutionException.java | 406 -
.../org/apache/storm/generated/HBMessage.java | 636 -
.../apache/storm/generated/HBMessageData.java | 640 -
.../jvm/org/apache/storm/generated/HBNodes.java | 461 -
.../jvm/org/apache/storm/generated/HBPulse.java | 522 -
.../org/apache/storm/generated/HBRecords.java | 466 -
.../storm/generated/HBServerMessageType.java | 113 -
.../generated/InvalidTopologyException.java | 406 -
.../org/apache/storm/generated/JavaObject.java | 561 -
.../apache/storm/generated/JavaObjectArg.java | 631 -
.../generated/KeyAlreadyExistsException.java | 406 -
.../storm/generated/KeyNotFoundException.java | 406 -
.../org/apache/storm/generated/KillOptions.java | 407 -
.../storm/generated/LSApprovedWorkers.java | 458 -
.../generated/LSSupervisorAssignments.java | 471 -
.../apache/storm/generated/LSSupervisorId.java | 406 -
.../apache/storm/generated/LSTopoHistory.java | 805 -
.../storm/generated/LSTopoHistoryList.java | 460 -
.../storm/generated/LSWorkerHeartbeat.java | 755 -
.../apache/storm/generated/ListBlobsResult.java | 556 -
.../apache/storm/generated/LocalAssignment.java | 676 -
.../apache/storm/generated/LocalStateData.java | 471 -
.../org/apache/storm/generated/LogConfig.java | 475 -
.../org/apache/storm/generated/LogLevel.java | 836 -
.../apache/storm/generated/LogLevelAction.java | 65 -
.../jvm/org/apache/storm/generated/Nimbus.java | 47241 -----------------
.../apache/storm/generated/NimbusSummary.java | 796 -
.../org/apache/storm/generated/NodeInfo.java | 556 -
.../storm/generated/NotAliveException.java | 406 -
.../org/apache/storm/generated/NullStruct.java | 300 -
.../apache/storm/generated/NumErrorsChoice.java | 65 -
.../apache/storm/generated/ProfileAction.java | 74 -
.../apache/storm/generated/ProfileRequest.java | 631 -
.../storm/generated/ReadableBlobMeta.java | 510 -
.../storm/generated/RebalanceOptions.java | 664 -
.../storm/generated/SettableBlobMeta.java | 567 -
.../apache/storm/generated/ShellComponent.java | 516 -
.../storm/generated/SpecificAggregateStats.java | 387 -
.../storm/generated/SpoutAggregateStats.java | 407 -
.../org/apache/storm/generated/SpoutSpec.java | 514 -
.../org/apache/storm/generated/SpoutStats.java | 917 -
.../apache/storm/generated/StateSpoutSpec.java | 514 -
.../org/apache/storm/generated/StormBase.java | 1382 -
.../apache/storm/generated/StormTopology.java | 1272 -
.../org/apache/storm/generated/StreamInfo.java | 554 -
.../apache/storm/generated/SubmitOptions.java | 533 -
.../apache/storm/generated/SupervisorInfo.java | 1446 -
.../storm/generated/SupervisorPageInfo.java | 624 -
.../storm/generated/SupervisorSummary.java | 1265 -
.../storm/generated/ThriftSerializedObject.java | 516 -
.../storm/generated/TopologyActionOptions.java | 387 -
.../storm/generated/TopologyHistoryInfo.java | 461 -
.../apache/storm/generated/TopologyInfo.java | 2144 -
.../storm/generated/TopologyInitialStatus.java | 62 -
.../storm/generated/TopologyPageInfo.java | 2757 -
.../apache/storm/generated/TopologyStats.java | 1094 -
.../apache/storm/generated/TopologyStatus.java | 68 -
.../apache/storm/generated/TopologySummary.java | 1901 -
.../apache/storm/generated/WorkerResources.java | 605 -
.../apache/storm/generated/WorkerSummary.java | 1880 -
.../storm/grouping/CustomStreamGrouping.java | 43 -
.../src/jvm/org/apache/storm/grouping/Load.java | 77 -
.../grouping/LoadAwareCustomStreamGrouping.java | 24 -
.../grouping/LoadAwareShuffleGrouping.java | 76 -
.../org/apache/storm/grouping/LoadMapping.java | 64 -
.../storm/grouping/PartialKeyGrouping.java | 106 -
.../apache/storm/grouping/ShuffleGrouping.java | 63 -
.../org/apache/storm/hooks/BaseTaskHook.java | 61 -
.../org/apache/storm/hooks/BaseWorkerHook.java | 51 -
.../jvm/org/apache/storm/hooks/ITaskHook.java | 38 -
.../jvm/org/apache/storm/hooks/IWorkerHook.java | 44 -
.../storm/hooks/SubmitterHookException.java | 41 -
.../apache/storm/hooks/info/BoltAckInfo.java | 40 -
.../storm/hooks/info/BoltExecuteInfo.java | 40 -
.../apache/storm/hooks/info/BoltFailInfo.java | 40 -
.../org/apache/storm/hooks/info/EmitInfo.java | 44 -
.../apache/storm/hooks/info/SpoutAckInfo.java | 39 -
.../apache/storm/hooks/info/SpoutFailInfo.java | 39 -
.../apache/storm/localizer/AsyncLocalizer.java | 436 -
.../org/apache/storm/localizer/ILocalizer.java | 70 -
.../localizer/LocalDownloadedResource.java | 146 -
.../apache/storm/localizer/LocalResource.java | 44 -
.../storm/localizer/LocalizedResource.java | 130 -
.../LocalizedResourceRetentionSet.java | 140 -
.../storm/localizer/LocalizedResourceSet.java | 101 -
.../org/apache/storm/localizer/Localizer.java | 702 -
.../storm/logging/ThriftAccessLogger.java | 56 -
.../logging/filters/AccessLoggingFilter.java | 52 -
.../storm/messaging/ConnectionWithStatus.java | 49 -
.../DeserializingConnectionCallback.java | 60 -
.../org/apache/storm/messaging/IConnection.java | 63 -
.../storm/messaging/IConnectionCallback.java | 31 -
.../org/apache/storm/messaging/IContext.java | 59 -
.../org/apache/storm/messaging/TaskMessage.java | 53 -
.../storm/messaging/TransportFactory.java | 57 -
.../apache/storm/messaging/local/Context.java | 218 -
.../apache/storm/messaging/netty/Client.java | 612 -
.../apache/storm/messaging/netty/Context.java | 113 -
.../storm/messaging/netty/ControlMessage.java | 75 -
.../messaging/netty/INettySerializable.java | 26 -
.../storm/messaging/netty/ISaslClient.java | 28 -
.../storm/messaging/netty/ISaslServer.java | 26 -
.../apache/storm/messaging/netty/IServer.java | 26 -
.../netty/KerberosSaslClientHandler.java | 154 -
.../netty/KerberosSaslNettyClient.java | 202 -
.../netty/KerberosSaslNettyClientState.java | 31 -
.../netty/KerberosSaslNettyServer.java | 209 -
.../netty/KerberosSaslNettyServerState.java | 30 -
.../netty/KerberosSaslServerHandler.java | 133 -
.../org/apache/storm/messaging/netty/Login.java | 411 -
.../storm/messaging/netty/MessageBatch.java | 118 -
.../storm/messaging/netty/MessageBuffer.java | 58 -
.../storm/messaging/netty/MessageDecoder.java | 144 -
.../storm/messaging/netty/MessageEncoder.java | 43 -
.../netty/NettyRenameThreadFactory.java | 56 -
.../netty/NettyUncaughtExceptionHandler.java | 35 -
.../storm/messaging/netty/SaslMessageToken.java | 114 -
.../storm/messaging/netty/SaslNettyClient.java | 154 -
.../messaging/netty/SaslNettyClientState.java | 31 -
.../storm/messaging/netty/SaslNettyServer.java | 157 -
.../messaging/netty/SaslNettyServerState.java | 30 -
.../messaging/netty/SaslStormClientHandler.java | 158 -
.../netty/SaslStormServerAuthorizeHandler.java | 83 -
.../messaging/netty/SaslStormServerHandler.java | 153 -
.../apache/storm/messaging/netty/SaslUtils.java | 68 -
.../apache/storm/messaging/netty/Server.java | 273 -
.../messaging/netty/StormClientHandler.java | 90 -
.../netty/StormClientPipelineFactory.java | 56 -
.../messaging/netty/StormServerHandler.java | 74 -
.../netty/StormServerPipelineFactory.java | 57 -
.../metric/ClusterMetricsConsumerExecutor.java | 89 -
.../apache/storm/metric/EventLoggerBolt.java | 67 -
.../storm/metric/FileBasedEventLogger.java | 122 -
.../metric/HttpForwardingMetricsConsumer.java | 85 -
.../metric/HttpForwardingMetricsServer.java | 118 -
.../org/apache/storm/metric/IEventLogger.java | 70 -
.../metric/LoggingClusterMetricsConsumer.java | 86 -
.../storm/metric/LoggingMetricsConsumer.java | 76 -
.../storm/metric/MetricsConsumerBolt.java | 146 -
.../storm/metric/StormMetricsRegistry.java | 88 -
.../jvm/org/apache/storm/metric/SystemBolt.java | 160 -
.../storm/metric/api/AssignableMetric.java | 34 -
.../apache/storm/metric/api/CombinedMetric.java | 38 -
.../apache/storm/metric/api/CountMetric.java | 39 -
.../org/apache/storm/metric/api/DataPoint.java | 43 -
.../metric/api/IClusterMetricsConsumer.java | 63 -
.../org/apache/storm/metric/api/ICombiner.java | 23 -
.../org/apache/storm/metric/api/IMetric.java | 30 -
.../storm/metric/api/IMetricsConsumer.java | 81 -
.../org/apache/storm/metric/api/IReducer.java | 24 -
.../storm/metric/api/IStatefulObject.java | 22 -
.../apache/storm/metric/api/MeanReducer.java | 53 -
.../storm/metric/api/MultiCountMetric.java | 45 -
.../storm/metric/api/MultiReducedMetric.java | 50 -
.../apache/storm/metric/api/ReducedMetric.java | 38 -
.../apache/storm/metric/api/StateMetric.java | 31 -
.../metric/api/rpc/AssignableShellMetric.java | 30 -
.../metric/api/rpc/CombinedShellMetric.java | 31 -
.../storm/metric/api/rpc/CountShellMetric.java | 37 -
.../storm/metric/api/rpc/IShellMetric.java | 31 -
.../metric/api/rpc/ReducedShellMetric.java | 32 -
.../apache/storm/metric/cgroup/CGroupCpu.java | 70 -
.../storm/metric/cgroup/CGroupCpuGuarantee.java | 52 -
.../storm/metric/cgroup/CGroupMemoryLimit.java | 39 -
.../storm/metric/cgroup/CGroupMemoryUsage.java | 39 -
.../storm/metric/cgroup/CGroupMetricsBase.java | 114 -
.../storm/metric/filter/FilterByMetricName.java | 110 -
.../storm/metric/filter/MetricsFilter.java | 26 -
.../metric/internal/CountStatAndMetric.java | 211 -
.../metric/internal/LatencyStatAndMetric.java | 262 -
.../storm/metric/internal/MetricStatTimer.java | 27 -
.../internal/MultiCountStatAndMetric.java | 112 -
.../internal/MultiLatencyStatAndMetric.java | 109 -
.../storm/metric/internal/RateTracker.java | 139 -
.../storm/metric/util/DataPointExpander.java | 79 -
.../jvm/org/apache/storm/multilang/BoltMsg.java | 79 -
.../org/apache/storm/multilang/ISerializer.java | 82 -
.../apache/storm/multilang/JsonSerializer.java | 203 -
.../storm/multilang/NoOutputException.java | 40 -
.../org/apache/storm/multilang/ShellMsg.java | 184 -
.../org/apache/storm/multilang/SpoutMsg.java | 50 -
.../AbstractDNSToSwitchMapping.java | 96 -
.../networktopography/DNSToSwitchMapping.java | 49 -
.../DefaultRackDNSToSwitchMapping.java | 52 -
.../storm/nimbus/DefaultTopologyValidator.java | 31 -
.../org/apache/storm/nimbus/ILeaderElector.java | 73 -
.../nimbus/ITopologyActionNotifierPlugin.java | 43 -
.../apache/storm/nimbus/ITopologyValidator.java | 28 -
.../jvm/org/apache/storm/nimbus/NimbusInfo.java | 120 -
.../storm/pacemaker/IServerMessageHandler.java | 25 -
.../org/apache/storm/pacemaker/Pacemaker.java | 218 -
.../apache/storm/pacemaker/PacemakerClient.java | 274 -
.../storm/pacemaker/PacemakerClientHandler.java | 80 -
.../storm/pacemaker/PacemakerClientPool.java | 113 -
.../pacemaker/PacemakerConnectionException.java | 24 -
.../apache/storm/pacemaker/PacemakerServer.java | 168 -
.../storm/pacemaker/codec/ThriftDecoder.java | 69 -
.../storm/pacemaker/codec/ThriftEncoder.java | 110 -
.../pacemaker/codec/ThriftNettyClientCodec.java | 97 -
.../pacemaker/codec/ThriftNettyServerCodec.java | 99 -
.../jvm/org/apache/storm/scheduler/Cluster.java | 855 -
.../storm/scheduler/DefaultScheduler.java | 111 -
.../apache/storm/scheduler/EvenScheduler.java | 171 -
.../apache/storm/scheduler/ExecutorDetails.java | 54 -
.../jvm/org/apache/storm/scheduler/INimbus.java | 49 -
.../org/apache/storm/scheduler/IScheduler.java | 40 -
.../org/apache/storm/scheduler/ISupervisor.java | 45 -
.../storm/scheduler/IsolationScheduler.java | 425 -
.../storm/scheduler/SchedulerAssignment.java | 61 -
.../scheduler/SchedulerAssignmentImpl.java | 135 -
.../storm/scheduler/SupervisorDetails.java | 138 -
.../org/apache/storm/scheduler/Topologies.java | 87 -
.../apache/storm/scheduler/TopologyDetails.java | 516 -
.../org/apache/storm/scheduler/WorkerSlot.java | 81 -
.../scheduler/multitenant/DefaultPool.java | 219 -
.../storm/scheduler/multitenant/FreePool.java | 125 -
.../scheduler/multitenant/IsolatedPool.java | 371 -
.../multitenant/MultitenantScheduler.java | 98 -
.../storm/scheduler/multitenant/Node.java | 340 -
.../storm/scheduler/multitenant/NodePool.java | 296 -
.../storm/scheduler/resource/Component.java | 54 -
.../storm/scheduler/resource/RAS_Node.java | 529 -
.../storm/scheduler/resource/RAS_Nodes.java | 138 -
.../resource/ResourceAwareScheduler.java | 435 -
.../storm/scheduler/resource/ResourceUtils.java | 206 -
.../scheduler/resource/SchedulingResult.java | 116 -
.../scheduler/resource/SchedulingState.java | 56 -
.../scheduler/resource/SchedulingStatus.java | 40 -
.../apache/storm/scheduler/resource/User.java | 350 -
.../eviction/DefaultEvictionStrategy.java | 126 -
.../strategies/eviction/IEvictionStrategy.java | 42 -
.../DefaultSchedulingPriorityStrategy.java | 80 -
.../priority/ISchedulingPriorityStrategy.java | 36 -
.../DefaultResourceAwareStrategy.java | 757 -
.../strategies/scheduling/IStrategy.java | 47 -
.../storm/security/INimbusCredentialPlugin.java | 47 -
.../auth/AbstractSaslClientCallbackHandler.java | 76 -
.../auth/AbstractSaslServerCallbackHandler.java | 94 -
.../apache/storm/security/auth/AuthUtils.java | 419 -
.../org/apache/storm/security/auth/AutoSSL.java | 161 -
.../auth/DefaultHttpCredentialsPlugin.java | 96 -
.../security/auth/DefaultPrincipalToLocal.java | 42 -
.../apache/storm/security/auth/IAuthorizer.java | 53 -
.../storm/security/auth/IAutoCredentials.java | 55 -
.../security/auth/ICredentialsRenewer.java | 40 -
.../auth/IGroupMappingServiceProvider.java | 42 -
.../security/auth/IHttpCredentialsPlugin.java | 48 -
.../storm/security/auth/IPrincipalToLocal.java | 41 -
.../storm/security/auth/ITransportPlugin.java | 57 -
.../security/auth/KerberosPrincipalToLocal.java | 45 -
.../storm/security/auth/NimbusPrincipal.java | 29 -
.../apache/storm/security/auth/ReqContext.java | 152 -
.../security/auth/SaslTransportPlugin.java | 180 -
.../security/auth/ShellBasedGroupsMapping.java | 99 -
.../security/auth/SimpleTransportPlugin.java | 163 -
.../security/auth/SingleUserPrincipal.java | 53 -
.../storm/security/auth/TBackoffConnect.java | 82 -
.../storm/security/auth/ThriftClient.java | 124 -
.../security/auth/ThriftConnectionType.java | 86 -
.../storm/security/auth/ThriftServer.java | 78 -
.../auth/authorizer/DRPCAuthorizerBase.java | 63 -
.../authorizer/DRPCSimpleACLAuthorizer.java | 177 -
.../auth/authorizer/DenyAuthorizer.java | 47 -
.../authorizer/ImpersonationAuthorizer.java | 172 -
.../auth/authorizer/NoopAuthorizer.java | 47 -
.../auth/authorizer/SimpleACLAuthorizer.java | 173 -
.../authorizer/SimpleWhitelistAuthorizer.java | 60 -
.../auth/digest/ClientCallbackHandler.java | 58 -
.../auth/digest/DigestSaslTransportPlugin.java | 68 -
.../auth/digest/ServerCallbackHandler.java | 85 -
.../storm/security/auth/kerberos/AutoTGT.java | 269 -
.../auth/kerberos/AutoTGTKrb5LoginModule.java | 112 -
.../kerberos/AutoTGTKrb5LoginModuleTest.java | 44 -
.../auth/kerberos/ClientCallbackHandler.java | 104 -
.../kerberos/KerberosSaslTransportPlugin.java | 262 -
.../security/auth/kerberos/NoOpTTrasport.java | 54 -
.../auth/kerberos/ServerCallbackHandler.java | 96 -
.../auth/kerberos/jaas_kerberos_cluster.conf | 49 -
.../auth/kerberos/jaas_kerberos_launcher.conf | 31 -
.../auth/plain/PlainClientCallbackHandler.java | 31 -
.../auth/plain/PlainSaslTransportPlugin.java | 71 -
.../auth/plain/PlainServerCallbackHandler.java | 55 -
.../security/auth/plain/SaslPlainServer.java | 158 -
.../serialization/BlowfishTupleSerializer.java | 92 -
.../storm/serialization/DefaultKryoFactory.java | 64 -
.../DefaultSerializationDelegate.java | 58 -
.../GzipBridgeSerializationDelegate.java | 65 -
.../GzipBridgeThriftSerializationDelegate.java | 64 -
.../GzipSerializationDelegate.java | 64 -
.../GzipThriftSerializationDelegate.java | 56 -
.../storm/serialization/IKryoDecorator.java | 23 -
.../storm/serialization/IKryoFactory.java | 40 -
.../storm/serialization/ITupleDeserializer.java | 24 -
.../storm/serialization/ITupleSerializer.java | 26 -
.../serialization/KryoTupleDeserializer.java | 56 -
.../serialization/KryoTupleSerializer.java | 60 -
.../serialization/KryoValuesDeserializer.java | 50 -
.../serialization/KryoValuesSerializer.java | 58 -
.../serialization/SerializableSerializer.java | 61 -
.../serialization/SerializationDelegate.java | 35 -
.../serialization/SerializationFactory.java | 240 -
.../ThriftSerializationDelegate.java | 52 -
.../types/ArrayListSerializer.java | 32 -
.../serialization/types/HashMapSerializer.java | 32 -
.../serialization/types/HashSetSerializer.java | 32 -
.../types/ListDelegateSerializer.java | 32 -
.../org/apache/storm/spout/CheckPointState.java | 172 -
.../org/apache/storm/spout/CheckpointSpout.java | 232 -
.../storm/spout/IMultiSchemableSpout.java | 23 -
.../org/apache/storm/spout/ISchemableSpout.java | 24 -
.../src/jvm/org/apache/storm/spout/ISpout.java | 105 -
.../storm/spout/ISpoutOutputCollector.java | 32 -
.../apache/storm/spout/ISpoutWaitStrategy.java | 34 -
.../jvm/org/apache/storm/spout/MultiScheme.java | 29 -
.../storm/spout/NothingEmptyEmitStrategy.java | 31 -
.../org/apache/storm/spout/RawMultiScheme.java | 40 -
.../jvm/org/apache/storm/spout/RawScheme.java | 37 -
.../src/jvm/org/apache/storm/spout/Scheme.java | 29 -
.../apache/storm/spout/SchemeAsMultiScheme.java | 42 -
.../jvm/org/apache/storm/spout/ShellSpout.java | 327 -
.../storm/spout/SleepSpoutWaitStrategy.java | 41 -
.../storm/spout/SpoutOutputCollector.java | 143 -
.../storm/state/DefaultStateSerializer.java | 77 -
.../jvm/org/apache/storm/state/IStateSpout.java | 29 -
.../storm/state/IStateSpoutOutputCollector.java | 22 -
.../apache/storm/state/ISubscribedState.java | 25 -
.../state/ISynchronizeOutputCollector.java | 24 -
.../storm/state/InMemoryKeyValueState.java | 126 -
.../state/InMemoryKeyValueStateProvider.java | 43 -
.../org/apache/storm/state/KeyValueState.java | 58 -
.../jvm/org/apache/storm/state/Serializer.java | 30 -
.../src/jvm/org/apache/storm/state/State.java | 55 -
.../org/apache/storm/state/StateFactory.java | 69 -
.../org/apache/storm/state/StateProvider.java | 38 -
.../storm/state/StateSpoutOutputCollector.java | 28 -
.../storm/state/SynchronizeOutputCollector.java | 30 -
.../apache/storm/stats/BoltExecutorStats.java | 106 -
.../jvm/org/apache/storm/stats/CommonStats.java | 114 -
.../apache/storm/stats/SpoutExecutorStats.java | 76 -
.../jvm/org/apache/storm/stats/StatsUtil.java | 2612 -
.../src/jvm/org/apache/storm/streams/Edge.java | 41 -
.../org/apache/storm/streams/GroupingInfo.java | 100 -
.../src/jvm/org/apache/storm/streams/Node.java | 170 -
.../src/jvm/org/apache/storm/streams/Pair.java | 103 -
.../org/apache/storm/streams/PairStream.java | 525 -
.../org/apache/storm/streams/PartitionNode.java | 37 -
.../org/apache/storm/streams/ProcessorBolt.java | 70 -
.../storm/streams/ProcessorBoltDelegate.java | 348 -
.../org/apache/storm/streams/ProcessorNode.java | 83 -
.../apache/storm/streams/RefCountedTuple.java | 64 -
.../jvm/org/apache/storm/streams/SinkNode.java | 44 -
.../jvm/org/apache/storm/streams/SpoutNode.java | 48 -
.../storm/streams/StatefulProcessorBolt.java | 116 -
.../jvm/org/apache/storm/streams/Stream.java | 515 -
.../org/apache/storm/streams/StreamBolt.java | 38 -
.../org/apache/storm/streams/StreamBuilder.java | 602 -
.../org/apache/storm/streams/StreamState.java | 43 -
.../org/apache/storm/streams/StreamUtil.java | 69 -
.../storm/streams/StreamsEdgeFactory.java | 29 -
.../org/apache/storm/streams/UniqueIdGen.java | 56 -
.../org/apache/storm/streams/WindowNode.java | 39 -
.../storm/streams/WindowedProcessorBolt.java | 137 -
.../storm/streams/operations/BiFunction.java | 37 -
.../streams/operations/CombinerAggregator.java | 97 -
.../storm/streams/operations/Consumer.java | 32 -
.../streams/operations/FlatMapFunction.java | 27 -
.../storm/streams/operations/Function.java | 34 -
.../streams/operations/IdentityFunction.java | 31 -
.../storm/streams/operations/Operation.java | 26 -
.../streams/operations/PairFlatMapFunction.java | 30 -
.../storm/streams/operations/PairFunction.java | 30 -
.../streams/operations/PairValueJoiner.java | 40 -
.../storm/streams/operations/Predicate.java | 33 -
.../storm/streams/operations/PrintConsumer.java | 30 -
.../storm/streams/operations/Reducer.java | 35 -
.../storm/streams/operations/StateUpdater.java | 67 -
.../storm/streams/operations/ValueJoiner.java | 36 -
.../streams/operations/aggregators/Count.java | 47 -
.../streams/operations/aggregators/LongSum.java | 45 -
.../operations/mappers/PairValueMapper.java | 51 -
.../operations/mappers/TupleValueMapper.java | 30 -
.../operations/mappers/TupleValueMappers.java | 174 -
.../streams/operations/mappers/ValueMapper.java | 45 -
.../operations/mappers/ValuesMapper.java | 48 -
.../processors/AggregateByKeyProcessor.java | 78 -
.../streams/processors/AggregateProcessor.java | 69 -
.../storm/streams/processors/BaseProcessor.java | 109 -
.../streams/processors/BatchProcessor.java | 25 -
.../streams/processors/BranchProcessor.java | 41 -
.../processors/ChainedProcessorContext.java | 66 -
.../processors/EmittingProcessorContext.java | 155 -
.../streams/processors/FilterProcessor.java | 35 -
.../streams/processors/FlatMapProcessor.java | 35 -
.../processors/FlatMapValuesProcessor.java | 36 -
.../streams/processors/ForEachProcessor.java | 33 -
.../processors/ForwardingProcessorContext.java | 102 -
.../storm/streams/processors/JoinProcessor.java | 152 -
.../storm/streams/processors/MapProcessor.java | 33 -
.../streams/processors/MapValuesProcessor.java | 34 -
.../MergeAggregateByKeyProcessor.java | 54 -
.../processors/MergeAggregateProcessor.java | 47 -
.../storm/streams/processors/PeekProcessor.java | 34 -
.../storm/streams/processors/Processor.java | 54 -
.../streams/processors/ProcessorContext.java | 62 -
.../processors/ReduceByKeyProcessor.java | 52 -
.../streams/processors/ReduceProcessor.java | 43 -
.../streams/processors/StateQueryProcessor.java | 48 -
.../streams/processors/StatefulProcessor.java | 36 -
.../processors/UpdateStateByKeyProcessor.java | 49 -
.../org/apache/storm/streams/tuple/Tuple10.java | 112 -
.../org/apache/storm/streams/tuple/Tuple3.java | 70 -
.../org/apache/storm/streams/tuple/Tuple4.java | 76 -
.../org/apache/storm/streams/tuple/Tuple5.java | 82 -
.../org/apache/storm/streams/tuple/Tuple6.java | 89 -
.../org/apache/storm/streams/tuple/Tuple7.java | 94 -
.../org/apache/storm/streams/tuple/Tuple8.java | 100 -
.../org/apache/storm/streams/tuple/Tuple9.java | 106 -
.../storm/streams/windowing/BaseWindow.java | 64 -
.../storm/streams/windowing/SlidingWindows.java | 151 -
.../streams/windowing/TumblingWindows.java | 119 -
.../apache/storm/streams/windowing/Window.java | 70 -
.../storm/task/GeneralTopologyContext.java | 202 -
.../src/jvm/org/apache/storm/task/IBolt.java | 84 -
.../org/apache/storm/task/IErrorReporter.java | 22 -
.../org/apache/storm/task/IMetricsContext.java | 31 -
.../org/apache/storm/task/IOutputCollector.java | 33 -
.../org/apache/storm/task/OutputCollector.java | 236 -
.../jvm/org/apache/storm/task/ShellBolt.java | 435 -
.../org/apache/storm/task/TopologyContext.java | 402 -
.../storm/task/WorkerTopologyContext.java | 106 -
.../apache/storm/testing/AckFailDelegate.java | 25 -
.../apache/storm/testing/AckFailMapTracker.java | 52 -
.../org/apache/storm/testing/AckTracker.java | 52 -
.../AlternateRackDNSToSwitchMapping.java | 65 -
.../apache/storm/testing/BatchNumberList.java | 72 -
.../apache/storm/testing/BatchProcessWord.java | 39 -
.../org/apache/storm/testing/BatchRepeatA.java | 48 -
.../org/apache/storm/testing/BoltTracker.java | 42 -
.../apache/storm/testing/CompletableSpout.java | 39 -
.../storm/testing/CompleteTopologyParam.java | 103 -
.../apache/storm/testing/CountingBatchBolt.java | 55 -
.../storm/testing/CountingCommitBolt.java | 57 -
.../org/apache/storm/testing/FeederSpout.java | 107 -
.../org/apache/storm/testing/FixedTuple.java | 42 -
.../apache/storm/testing/FixedTupleSpout.java | 184 -
.../testing/ForwardingMetricsConsumer.java | 100 -
.../org/apache/storm/testing/IdentityBolt.java | 42 -
.../storm/testing/InProcessZookeeper.java | 59 -
.../apache/storm/testing/IntegrationTest.java | 38 -
.../storm/testing/KeyedCountingBatchBolt.java | 61 -
.../testing/KeyedCountingCommitterBolt.java | 24 -
.../storm/testing/KeyedSummingBatchBolt.java | 61 -
.../storm/testing/MemoryTransactionalSpout.java | 180 -
.../testing/MemoryTransactionalSpoutMeta.java | 38 -
.../apache/storm/testing/MkClusterParam.java | 69 -
.../org/apache/storm/testing/MkTupleParam.java | 58 -
.../org/apache/storm/testing/MockedSources.java | 68 -
.../jvm/org/apache/storm/testing/NGrouping.java | 48 -
.../storm/testing/NonRichBoltTracker.java | 51 -
.../testing/OpaqueMemoryTransactionalSpout.java | 186 -
.../apache/storm/testing/PrepareBatchBolt.java | 52 -
.../storm/testing/PythonShellMetricsBolt.java | 53 -
.../storm/testing/PythonShellMetricsSpout.java | 56 -
.../testing/SingleUserSimpleTransport.java | 37 -
.../org/apache/storm/testing/SpoutTracker.java | 111 -
.../storm/testing/TestAggregatesCounter.java | 63 -
.../org/apache/storm/testing/TestConfBolt.java | 62 -
.../apache/storm/testing/TestEventLogSpout.java | 144 -
.../storm/testing/TestEventOrderCheckBolt.java | 76 -
.../apache/storm/testing/TestGlobalCount.java | 60 -
.../jvm/org/apache/storm/testing/TestJob.java | 43 -
.../apache/storm/testing/TestKryoDecorator.java | 31 -
.../apache/storm/testing/TestPlannerBolt.java | 45 -
.../apache/storm/testing/TestPlannerSpout.java | 85 -
.../org/apache/storm/testing/TestSerObject.java | 37 -
.../storm/testing/TestWordBytesCounter.java | 27 -
.../apache/storm/testing/TestWordCounter.java | 65 -
.../org/apache/storm/testing/TestWordSpout.java | 86 -
.../jvm/org/apache/storm/testing/TmpPath.java | 69 -
.../apache/storm/testing/TrackedTopology.java | 135 -
.../apache/storm/testing/TupleCaptureBolt.java | 83 -
.../staticmocking/MockedClientZookeeper.java | 32 +
.../topology/BaseConfigurationDeclarer.java | 84 -
.../topology/BaseStatefulBoltExecutor.java | 209 -
.../storm/topology/BasicBoltExecutor.java | 67 -
.../storm/topology/BasicOutputCollector.java | 72 -
.../org/apache/storm/topology/BoltDeclarer.java | 26 -
.../topology/CheckpointTupleForwarder.java | 103 -
.../ComponentConfigurationDeclarer.java | 29 -
.../storm/topology/ConfigurableTopology.java | 184 -
.../apache/storm/topology/FailedException.java | 36 -
.../org/apache/storm/topology/IBasicBolt.java | 33 -
.../storm/topology/IBasicOutputCollector.java | 29 -
.../org/apache/storm/topology/IComponent.java | 44 -
.../org/apache/storm/topology/IRichBolt.java | 29 -
.../org/apache/storm/topology/IRichSpout.java | 29 -
.../apache/storm/topology/IRichStateSpout.java | 25 -
.../apache/storm/topology/IStatefulBolt.java | 48 -
.../storm/topology/IStatefulComponent.java | 56 -
.../storm/topology/IStatefulWindowedBolt.java | 26 -
.../apache/storm/topology/IWindowedBolt.java | 51 -
.../apache/storm/topology/InputDeclarer.java | 184 -
.../storm/topology/OutputFieldsDeclarer.java | 32 -
.../storm/topology/OutputFieldsGetter.java | 53 -
.../storm/topology/ReportedFailedException.java | 36 -
.../apache/storm/topology/ResourceDeclarer.java | 28 -
.../apache/storm/topology/SpoutDeclarer.java | 22 -
.../storm/topology/StatefulBoltExecutor.java | 193 -
.../topology/StatefulWindowedBoltExecutor.java | 372 -
.../apache/storm/topology/TopologyBuilder.java | 588 -
.../topology/TupleFieldTimestampExtractor.java | 48 -
.../storm/topology/WindowedBoltExecutor.java | 363 -
.../storm/topology/base/BaseBasicBolt.java | 33 -
.../storm/topology/base/BaseBatchBolt.java | 24 -
.../storm/topology/base/BaseComponent.java | 28 -
...BaseOpaquePartitionedTransactionalSpout.java | 25 -
.../base/BasePartitionedTransactionalSpout.java | 25 -
.../storm/topology/base/BaseRichBolt.java | 26 -
.../storm/topology/base/BaseRichSpout.java | 46 -
.../storm/topology/base/BaseStatefulBolt.java | 64 -
.../topology/base/BaseStatefulWindowedBolt.java | 168 -
.../base/BaseTickTupleAwareRichBolt.java | 60 -
.../topology/base/BaseTransactionalBolt.java | 24 -
.../topology/base/BaseTransactionalSpout.java | 24 -
.../storm/topology/base/BaseWindowedBolt.java | 365 -
.../apache/storm/transactional/ICommitter.java | 26 -
.../ICommitterTransactionalSpout.java | 31 -
.../transactional/ITransactionalSpout.java | 94 -
.../storm/transactional/TransactionAttempt.java | 61 -
.../TransactionalSpoutBatchExecutor.java | 96 -
.../TransactionalSpoutCoordinator.java | 212 -
.../TransactionalTopologyBuilder.java | 521 -
.../IOpaquePartitionedTransactionalSpout.java | 56 -
.../IPartitionedTransactionalSpout.java | 69 -
...uePartitionedTransactionalSpoutExecutor.java | 160 -
.../PartitionedTransactionalSpoutExecutor.java | 142 -
.../state/RotatingTransactionalState.java | 149 -
.../state/TestTransactionalState.java | 47 -
.../transactional/state/TransactionalState.java | 173 -
.../apache/storm/trident/JoinOutFieldsMode.java | 33 -
.../jvm/org/apache/storm/trident/JoinType.java | 30 -
.../jvm/org/apache/storm/trident/Stream.java | 897 -
.../org/apache/storm/trident/TridentState.java | 59 -
.../apache/storm/trident/TridentTopology.java | 986 -
.../trident/drpc/ReturnResultsReducer.java | 128 -
.../fluent/ChainedAggregatorDeclarer.java | 183 -
.../fluent/ChainedFullAggregatorDeclarer.java | 32 -
.../ChainedPartitionAggregatorDeclarer.java | 32 -
.../trident/fluent/GlobalAggregationScheme.java | 26 -
.../storm/trident/fluent/GroupedStream.java | 174 -
.../trident/fluent/IAggregatableStream.java | 31 -
.../fluent/IChainedAggregatorDeclarer.java | 24 -
.../storm/trident/fluent/UniqueIdGen.java | 38 -
.../storm/trident/graph/GraphGrouper.java | 119 -
.../org/apache/storm/trident/graph/Group.java | 150 -
.../storm/trident/operation/Aggregator.java | 26 -
.../storm/trident/operation/Assembly.java | 45 -
.../storm/trident/operation/BaseAggregator.java | 23 -
.../storm/trident/operation/BaseFilter.java | 23 -
.../storm/trident/operation/BaseFunction.java | 23 -
.../trident/operation/BaseMultiReducer.java | 33 -
.../storm/trident/operation/BaseOperation.java | 47 -
.../trident/operation/CombinerAggregator.java | 29 -
.../storm/trident/operation/Consumer.java | 35 -
.../operation/DefaultResourceDeclarer.java | 68 -
.../storm/trident/operation/EachOperation.java | 22 -
.../apache/storm/trident/operation/Filter.java | 48 -
.../trident/operation/FlatMapFunction.java | 37 -
.../storm/trident/operation/Function.java | 92 -
.../trident/operation/GroupedMultiReducer.java | 31 -
.../trident/operation/ITridentResource.java | 32 -
.../storm/trident/operation/MapFunction.java | 36 -
.../storm/trident/operation/MultiReducer.java | 31 -
.../storm/trident/operation/Operation.java | 46 -
.../OperationAwareFlatMapFunction.java | 24 -
.../operation/OperationAwareMapFunction.java | 24 -
.../trident/operation/ReducerAggregator.java | 26 -
.../trident/operation/TridentCollector.java | 52 -
.../operation/TridentMultiReducerContext.java | 36 -
.../operation/TridentOperationContext.java | 65 -
.../operation/builtin/ComparisonAggregator.java | 91 -
.../storm/trident/operation/builtin/Count.java | 41 -
.../storm/trident/operation/builtin/Debug.java | 62 -
.../storm/trident/operation/builtin/Equals.java | 38 -
.../trident/operation/builtin/FilterNull.java | 35 -
.../storm/trident/operation/builtin/FirstN.java | 130 -
.../storm/trident/operation/builtin/MapGet.java | 38 -
.../storm/trident/operation/builtin/Max.java | 37 -
.../operation/builtin/MaxWithComparator.java | 51 -
.../storm/trident/operation/builtin/Min.java | 36 -
.../operation/builtin/MinWithComparator.java | 51 -
.../storm/trident/operation/builtin/Negate.java | 76 -
.../trident/operation/builtin/SnapshotGet.java | 44 -
.../storm/trident/operation/builtin/Sum.java | 42 -
.../operation/builtin/TupleCollectionGet.java | 46 -
.../operation/impl/CaptureCollector.java | 42 -
.../operation/impl/ChainedAggregatorImpl.java | 113 -
.../trident/operation/impl/ChainedResult.java | 53 -
.../operation/impl/CombinerAggStateUpdater.java | 56 -
.../impl/CombinerAggregatorCombineImpl.java | 61 -
.../impl/CombinerAggregatorInitImpl.java | 49 -
.../operation/impl/ConsumerExecutor.java | 38 -
.../trident/operation/impl/FilterExecutor.java | 53 -
.../operation/impl/FlatMapFunctionExecutor.java | 64 -
.../operation/impl/GlobalBatchToPartition.java | 29 -
.../trident/operation/impl/GroupCollector.java | 48 -
.../operation/impl/GroupedAggregator.java | 96 -
.../impl/GroupedMultiReducerExecutor.java | 95 -
.../operation/impl/IdentityMultiReducer.java | 51 -
.../impl/IndexHashBatchToPartition.java | 29 -
.../storm/trident/operation/impl/JoinState.java | 39 -
.../operation/impl/JoinerMultiReducer.java | 142 -
.../operation/impl/MapFunctionExecutor.java | 62 -
...PreservingFieldsOrderJoinerMultiReducer.java | 175 -
.../operation/impl/ReducerAggStateUpdater.java | 53 -
.../operation/impl/ReducerAggregatorImpl.java | 56 -
.../storm/trident/operation/impl/Result.java | 27 -
.../operation/impl/SingleEmitAggregator.java | 95 -
.../trident/operation/impl/TrueFilter.java | 40 -
.../storm/trident/partition/GlobalGrouping.java | 42 -
.../trident/partition/IdentityGrouping.java | 59 -
.../trident/partition/IndexHashGrouping.java | 55 -
.../storm/trident/planner/BridgeReceiver.java | 38 -
.../org/apache/storm/trident/planner/Node.java | 69 -
.../storm/trident/planner/NodeStateInfo.java | 31 -
.../storm/trident/planner/PartitionNode.java | 50 -
.../storm/trident/planner/ProcessorContext.java | 29 -
.../storm/trident/planner/ProcessorNode.java | 38 -
.../apache/storm/trident/planner/SpoutNode.java | 39 -
.../storm/trident/planner/SubtopologyBolt.java | 246 -
.../storm/trident/planner/TridentProcessor.java | 40 -
.../storm/trident/planner/TupleReceiver.java | 27 -
.../planner/processor/AggregateProcessor.java | 84 -
.../planner/processor/AppendCollector.java | 62 -
.../planner/processor/EachProcessor.java | 80 -
.../planner/processor/FreshCollector.java | 59 -
.../trident/planner/processor/MapProcessor.java | 87 -
.../processor/MultiReducerProcessor.java | 93 -
.../processor/PartitionPersistProcessor.java | 107 -
.../planner/processor/ProjectedProcessor.java | 73 -
.../planner/processor/StateQueryProcessor.java | 107 -
.../planner/processor/TridentContext.java | 76 -
.../storm/trident/spout/BatchSpoutExecutor.java | 92 -
.../apache/storm/trident/spout/IBatchID.java | 24 -
.../apache/storm/trident/spout/IBatchSpout.java | 33 -
.../trident/spout/ICommitterTridentSpout.java | 31 -
.../spout/IOpaquePartitionedTridentSpout.java | 87 -
.../trident/spout/IPartitionedTridentSpout.java | 77 -
.../storm/trident/spout/ISpoutPartition.java | 25 -
.../storm/trident/spout/ITridentDataSource.java | 26 -
.../storm/trident/spout/ITridentSpout.java | 125 -
.../OpaquePartitionedTridentSpoutExecutor.java | 234 -
.../spout/PartitionedTridentSpoutExecutor.java | 188 -
.../trident/spout/RichSpoutBatchExecutor.java | 204 -
.../storm/trident/spout/RichSpoutBatchId.java | 49 -
.../spout/RichSpoutBatchIdSerializer.java | 38 -
.../trident/spout/RichSpoutBatchTriggerer.java | 182 -
.../trident/spout/TridentSpoutCoordinator.java | 94 -
.../trident/spout/TridentSpoutExecutor.java | 138 -
.../storm/trident/state/BaseQueryFunction.java | 25 -
.../storm/trident/state/BaseStateUpdater.java | 25 -
.../trident/state/CombinerValueUpdater.java | 45 -
.../storm/trident/state/ITupleCollection.java | 26 -
.../state/JSONNonTransactionalSerializer.java | 45 -
.../trident/state/JSONOpaqueSerializer.java | 52 -
.../state/JSONTransactionalSerializer.java | 50 -
.../apache/storm/trident/state/OpaqueValue.java | 75 -
.../storm/trident/state/QueryFunction.java | 28 -
.../storm/trident/state/ReadOnlyState.java | 31 -
.../trident/state/ReducerValueUpdater.java | 41 -
.../apache/storm/trident/state/Serializer.java | 26 -
.../org/apache/storm/trident/state/State.java | 39 -
.../storm/trident/state/StateFactory.java | 26 -
.../apache/storm/trident/state/StateSpec.java | 30 -
.../apache/storm/trident/state/StateType.java | 25 -
.../storm/trident/state/StateUpdater.java | 33 -
.../storm/trident/state/TransactionalValue.java | 44 -
.../storm/trident/state/ValueUpdater.java | 23 -
.../trident/state/map/CachedBatchReadsMap.java | 80 -
.../storm/trident/state/map/CachedMap.java | 78 -
.../storm/trident/state/map/IBackingMap.java | 26 -
.../state/map/MapCombinerAggStateUpdater.java | 84 -
.../state/map/MapReducerAggStateUpdater.java | 91 -
.../storm/trident/state/map/MapState.java | 26 -
.../state/map/MicroBatchIBackingMap.java | 85 -
.../trident/state/map/NonTransactionalMap.java | 67 -
.../storm/trident/state/map/OpaqueMap.java | 124 -
.../trident/state/map/ReadOnlyMapState.java | 26 -
.../trident/state/map/RemovableMapState.java | 25 -
.../trident/state/map/SnapshottableMap.java | 76 -
.../trident/state/map/TransactionalMap.java | 109 -
.../state/snapshot/ReadOnlySnapshottable.java | 24 -
.../trident/state/snapshot/Snapshottable.java | 27 -
.../trident/testing/CountAsAggregator.java | 47 -
.../storm/trident/testing/FeederBatchSpout.java | 185 -
.../testing/FeederCommitterBatchSpout.java | 96 -
.../storm/trident/testing/FixedBatchSpout.java | 97 -
.../apache/storm/trident/testing/IFeeder.java | 23 -
.../trident/testing/LRUMemoryMapState.java | 154 -
.../storm/trident/testing/MemoryBackingMap.java | 47 -
.../storm/trident/testing/MemoryMapState.java | 176 -
.../org/apache/storm/trident/testing/Split.java | 36 -
.../storm/trident/testing/StringLength.java | 32 -
.../storm/trident/testing/TrueFilter.java | 30 -
.../storm/trident/testing/TuplifyArgs.java | 41 -
.../storm/trident/topology/BatchInfo.java | 33 -
.../trident/topology/ITridentBatchBolt.java | 32 -
.../topology/MasterBatchCoordinator.java | 316 -
.../trident/topology/TransactionAttempt.java | 66 -
.../trident/topology/TridentBoltExecutor.java | 439 -
.../topology/TridentTopologyBuilder.java | 751 -
.../state/RotatingTransactionalState.java | 186 -
.../topology/state/TestTransactionalState.java | 47 -
.../topology/state/TransactionalState.java | 191 -
.../apache/storm/trident/tuple/ComboList.java | 92 -
.../apache/storm/trident/tuple/ConsList.java | 60 -
.../storm/trident/tuple/TridentTuple.java | 34 -
.../storm/trident/tuple/TridentTupleView.java | 361 -
.../storm/trident/tuple/ValuePointer.java | 60 -
.../storm/trident/util/ErrorEdgeFactory.java | 28 -
.../apache/storm/trident/util/IndexedEdge.java | 50 -
.../org/apache/storm/trident/util/LRUMap.java | 35 -
.../apache/storm/trident/util/TridentUtils.java | 117 -
.../windowing/AbstractTridentWindowManager.java | 238 -
.../windowing/ITridentWindowManager.java | 59 -
.../windowing/InMemoryTridentWindowManager.java | 72 -
.../trident/windowing/InMemoryWindowsStore.java | 200 -
.../windowing/InMemoryWindowsStoreFactory.java | 44 -
.../StoreBasedTridentWindowManager.java | 217 -
.../trident/windowing/TridentBatchTuple.java | 42 -
.../trident/windowing/WindowKryoSerializer.java | 87 -
.../windowing/WindowTridentProcessor.java | 265 -
.../storm/trident/windowing/WindowsState.java | 52 -
.../trident/windowing/WindowsStateFactory.java | 40 -
.../trident/windowing/WindowsStateUpdater.java | 81 -
.../storm/trident/windowing/WindowsStore.java | 79 -
.../trident/windowing/WindowsStoreFactory.java | 40 -
.../windowing/config/BaseWindowConfig.java | 48 -
.../windowing/config/SlidingCountWindow.java | 43 -
.../windowing/config/SlidingDurationWindow.java | 44 -
.../windowing/config/TumblingCountWindow.java | 43 -
.../config/TumblingDurationWindow.java | 42 -
.../trident/windowing/config/WindowConfig.java | 57 -
.../windowing/strategy/BaseWindowStrategy.java | 32 -
.../strategy/SlidingCountWindowStrategy.java | 59 -
.../strategy/SlidingDurationWindowStrategy.java | 60 -
.../strategy/TumblingCountWindowStrategy.java | 60 -
.../TumblingDurationWindowStrategy.java | 60 -
.../windowing/strategy/WindowStrategy.java | 45 -
.../org/apache/storm/tuple/AddressedTuple.java | 48 -
.../src/jvm/org/apache/storm/tuple/Fields.java | 142 -
.../src/jvm/org/apache/storm/tuple/ITuple.java | 214 -
.../jvm/org/apache/storm/tuple/MessageId.java | 94 -
.../src/jvm/org/apache/storm/tuple/Tuple.java | 68 -
.../jvm/org/apache/storm/tuple/TupleImpl.java | 356 -
.../src/jvm/org/apache/storm/tuple/Values.java | 37 -
.../src/jvm/org/apache/storm/ui/UIHelpers.java | 8 +-
.../jvm/org/apache/storm/utils/BatchHelper.java | 92 -
.../storm/utils/BufferFileInputStream.java | 54 -
.../apache/storm/utils/BufferInputStream.java | 54 -
.../apache/storm/utils/CRC32OutputStream.java | 44 -
.../jvm/org/apache/storm/utils/ConfigUtils.java | 536 -
.../jvm/org/apache/storm/utils/DRPCClient.java | 66 -
.../utils/DisruptorBackpressureCallback.java | 27 -
.../org/apache/storm/utils/DisruptorQueue.java | 589 -
.../storm/utils/ExtendedThreadPoolExecutor.java | 67 -
.../jvm/org/apache/storm/utils/IPredicate.java | 27 -
.../storm/utils/IndifferentAccessMap.java | 177 -
.../org/apache/storm/utils/InprocMessaging.java | 100 -
.../storm/utils/KeyedRoundRobinQueue.java | 68 -
.../org/apache/storm/utils/ListDelegate.java | 156 -
.../jvm/org/apache/storm/utils/LocalState.java | 277 -
.../jvm/org/apache/storm/utils/MutableInt.java | 43 -
.../jvm/org/apache/storm/utils/MutableLong.java | 43 -
.../org/apache/storm/utils/MutableObject.java | 38 -
.../org/apache/storm/utils/NimbusClient.java | 139 -
.../utils/NimbusLeaderNotFoundException.java | 41 -
.../storm/utils/RegisteredGlobalState.java | 62 -
.../jvm/org/apache/storm/utils/RotatingMap.java | 128 -
.../org/apache/storm/utils/ServiceRegistry.java | 47 -
.../storm/utils/ShellBoltMessageQueue.java | 121 -
.../org/apache/storm/utils/ShellProcess.java | 215 -
.../jvm/org/apache/storm/utils/ShellUtils.java | 505 -
.../StormBoundedExponentialBackoffRetry.java | 79 -
.../storm/utils/StormCommonInstaller.java | 43 -
.../utils/StormConnectionStateConverter.java | 44 -
.../apache/storm/utils/ThriftTopologyUtils.java | 70 -
.../src/jvm/org/apache/storm/utils/Time.java | 235 -
.../org/apache/storm/utils/TimeCacheMap.java | 125 -
.../apache/storm/utils/TopologySpoutLag.java | 2 +
.../org/apache/storm/utils/TransferDrainer.java | 140 -
.../jvm/org/apache/storm/utils/TupleUtils.java | 67 -
.../src/jvm/org/apache/storm/utils/Utils.java | 2320 -
.../jvm/org/apache/storm/utils/VersionInfo.java | 131 -
.../org/apache/storm/utils/VersionedStore.java | 188 -
.../jvm/org/apache/storm/utils/WebAppUtils.java | 31 +
.../storm/utils/WindowedTimeThrottler.java | 51 -
.../storm/utils/WorkerBackpressureCallback.java | 26 -
.../storm/utils/WorkerBackpressureThread.java | 80 -
.../org/apache/storm/utils/WritableUtils.java | 375 -
.../apache/storm/utils/ZookeeperAuthInfo.java | 53 -
.../storm/utils/ZookeeperServerCnxnFactory.java | 84 -
.../storm/validation/ConfigValidation.java | 716 -
.../validation/ConfigValidationAnnotations.java | 218 -
.../storm/validation/ConfigValidationUtils.java | 175 -
.../storm/windowing/CountEvictionPolicy.java | 81 -
.../storm/windowing/CountTriggerPolicy.java | 76 -
.../storm/windowing/DefaultEvictionContext.java | 53 -
.../jvm/org/apache/storm/windowing/Event.java | 49 -
.../org/apache/storm/windowing/EventImpl.java | 51 -
.../apache/storm/windowing/EvictionContext.java | 47 -
.../apache/storm/windowing/EvictionPolicy.java | 82 -
.../storm/windowing/TimeEvictionPolicy.java | 72 -
.../storm/windowing/TimeTriggerPolicy.java | 132 -
.../storm/windowing/TimestampExtractor.java | 35 -
.../apache/storm/windowing/TriggerHandler.java | 31 -
.../apache/storm/windowing/TriggerPolicy.java | 49 -
.../org/apache/storm/windowing/TupleWindow.java | 26 -
.../apache/storm/windowing/TupleWindowImpl.java | 93 -
.../apache/storm/windowing/WaterMarkEvent.java | 38 -
.../windowing/WaterMarkEventGenerator.java | 121 -
.../windowing/WatermarkCountEvictionPolicy.java | 68 -
.../windowing/WatermarkCountTriggerPolicy.java | 91 -
.../windowing/WatermarkTimeEvictionPolicy.java | 77 -
.../windowing/WatermarkTimeTriggerPolicy.java | 126 -
.../jvm/org/apache/storm/windowing/Window.java | 55 -
.../windowing/WindowLifecycleListener.java | 43 -
.../apache/storm/windowing/WindowManager.java | 289 -
.../storm/zookeeper/LeaderElectorImp.java | 124 -
.../apache/storm/zookeeper/ZkEventTypes.java | 43 -
.../apache/storm/zookeeper/ZkKeeperStates.java | 41 -
.../org/apache/storm/zookeeper/Zookeeper.java | 545 -
storm-core/src/py/__init__.py | 18 -
storm-core/src/py/storm/DistributedRPC-remote | 112 -
storm-core/src/py/storm/DistributedRPC.py | 311 -
.../py/storm/DistributedRPCInvocations-remote | 133 -
.../src/py/storm/DistributedRPCInvocations.py | 886 -
storm-core/src/py/storm/Nimbus-remote | 420 -
storm-core/src/py/storm/Nimbus.py | 9915 ----
storm-core/src/py/storm/__init__.py | 19 -
storm-core/src/py/storm/constants.py | 29 -
storm-core/src/py/storm/ttypes.py | 11695 ----
storm-core/src/py_license_header.txt | 18 -
storm-core/src/storm.thrift | 775 -
.../org/apache/storm/integration_test.clj | 6 +-
.../org/apache/storm/testing4j_test.clj | 8 +-
.../test/clj/org/apache/storm/cluster_test.clj | 14 +-
.../test/clj/org/apache/storm/drpc_test.clj | 21 +-
.../test/clj/org/apache/storm/grouping_test.clj | 28 +-
.../clj/org/apache/storm/logviewer_test.clj | 2 +-
.../apache/storm/messaging/netty_unit_test.clj | 36 +-
.../test/clj/org/apache/storm/metrics_test.clj | 11 +-
.../test/clj/org/apache/storm/nimbus_test.clj | 18 +-
.../apache/storm/security/auth/auth_test.clj | 17 +-
.../storm/security/auth/nimbus_auth_test.clj | 18 +-
.../clj/org/apache/storm/trident/state_test.clj | 3 +-
.../jvm/org/apache/storm/MessagingTest.java | 68 -
.../storm/PaceMakerStateStorageFactoryTest.java | 155 -
.../jvm/org/apache/storm/PacemakerTest.java | 242 -
.../test/jvm/org/apache/storm/TestCgroups.java | 129 -
.../org/apache/storm/TestConfigValidate.java | 801 -
.../jvm/org/apache/storm/TickTupleTest.java | 102 -
.../apache/storm/blobstore/BlobStoreTest.java | 469 -
.../storm/blobstore/BlobSynchronizerTest.java | 137 -
.../storm/blobstore/ClientBlobStoreTest.java | 179 -
.../jvm/org/apache/storm/bolt/TestJoinBolt.java | 357 -
.../cluster/StormClusterStateImplTest.java | 116 -
.../org/apache/storm/daemon/drpc/DRPCTest.java | 252 -
.../daemon/supervisor/BasicContainerTest.java | 485 -
.../storm/daemon/supervisor/ContainerTest.java | 269 -
.../storm/daemon/supervisor/SlotTest.java | 498 -
.../daemon/worker/LogConfigManagerTest.java | 202 -
.../apache/storm/daemon/worker/WorkerTest.java | 39 -
.../DependencyPropertiesParserTest.java | 72 -
.../dependency/DependencyUploaderTest.java | 297 -
.../storm/executor/error/ReportErrorTest.java | 74 -
.../storm/grouping/PartialKeyGroupingTest.java | 66 -
.../storm/grouping/ShuffleGroupingTest.java | 147 -
.../storm/localizer/AsyncLocalizerTest.java | 187 -
.../LocalizedResourceRetentionSetTest.java | 85 -
.../localizer/LocalizedResourceSetTest.java | 74 -
.../apache/storm/localizer/LocalizerTest.java | 672 -
.../org/apache/storm/localizer/localtest.zip | Bin 6378 -> 0 bytes
.../storm/localizer/localtestwithsymlink.jar | Bin 6591 -> 0 bytes
.../storm/localizer/localtestwithsymlink.tar | Bin 24576 -> 0 bytes
.../storm/localizer/localtestwithsymlink.tar.gz | Bin 6106 -> 0 bytes
.../storm/localizer/localtestwithsymlink.tgz | Bin 6106 -> 0 bytes
.../ClusterMetricsConsumerExecutorTest.java | 133 -
.../metric/filter/FilterByMetricNameTest.java | 95 -
.../metric/internal/CountStatAndMetricTest.java | 86 -
.../internal/LatencyStatAndMetricTest.java | 83 -
.../storm/metric/internal/RateTrackerTest.java | 94 -
.../metric/util/DataPointExpanderTest.java | 109 -
.../apache/storm/nimbus/LocalNimbusTest.java | 132 -
.../resource/TestResourceAwareScheduler.java | 1366 -
.../storm/scheduler/resource/TestUser.java | 111 -
.../TestUtilsForResourceAwareScheduler.java | 369 -
.../eviction/TestDefaultEvictionStrategy.java | 751 -
.../TestDefaultResourceAwareStrategy.java | 331 -
.../storm/security/auth/AuthUtilsTest.java | 240 -
.../storm/security/auth/AuthUtilsTestMock.java | 82 -
.../apache/storm/security/auth/AutoSSLTest.java | 136 -
.../auth/DefaultHttpCredentialsPluginTest.java | 90 -
.../storm/security/auth/ReqContextTest.java | 87 -
.../security/auth/SaslTransportPluginTest.java | 49 -
.../storm/security/auth/ThriftClientTest.java | 68 -
.../storm/security/auth/ThriftServerTest.java | 38 -
.../authorizer/DRPCSimpleACLAuthorizerTest.java | 163 -
.../BlowfishTupleSerializerTest.java | 86 -
.../GzipBridgeSerializationDelegateTest.java | 82 -
...ipBridgeThriftSerializationDelegateTest.java | 71 -
.../serialization/SerializationFactoryTest.java | 61 -
.../storm/serialization/SerializationTest.java | 7 +-
.../ThriftBridgeSerializationDelegateTest.java | 60 -
.../apache/storm/spout/CheckpointSpoutTest.java | 262 -
.../storm/state/InMemoryKeyValueStateTest.java | 99 -
.../apache/storm/streams/ProcessorBoltTest.java | 174 -
.../streams/StatefulProcessorBoltTest.java | 111 -
.../apache/storm/streams/StreamBuilderTest.java | 268 -
.../streams/WindowedProcessorBoltTest.java | 110 -
.../streams/processors/JoinProcessorTest.java | 125 -
.../topology/StatefulBoltExecutorTest.java | 178 -
.../StatefulWindowedBoltExecutorTest.java | 131 -
.../storm/topology/TopologyBuilderTest.java | 118 -
.../topology/WindowedBoltExecutorTest.java | 230 -
.../storm/trident/TestTridentTopology.java | 76 -
.../storm/trident/TridentWindowingTest.java | 105 -
.../jvm/org/apache/storm/tuple/FieldsTest.java | 126 -
.../utils/DisruptorQueueBackpressureTest.java | 110 -
.../apache/storm/utils/DisruptorQueueTest.java | 187 -
.../apache/storm/utils/MockTupleHelpers.java | 40 -
.../storm/utils/ShellBoltMessageQueueTest.java | 85 -
...StormBoundedExponentialBackoffRetryTest.java | 101 -
.../storm/utils/ThriftTopologyUtilsTest.java | 106 -
.../utils/ThrowableNestedCauseMatcher.java | 44 -
.../jvm/org/apache/storm/utils/TimeTest.java | 95 -
.../jvm/org/apache/storm/utils/UtilsTest.java | 219 -
.../utils/WorkerBackpressureThreadTest.java | 50 -
.../utils/ZookeeperServerCnxnFactoryTest.java | 39 -
.../staticmocking/ConfigUtilsInstaller.java | 13 +-
.../staticmocking/ReflectionUtilsInstaller.java | 39 +
.../ServerConfigUtilsInstaller.java | 41 +
.../utils/staticmocking/UtilsInstaller.java | 13 +-
.../windowing/WaterMarkEventGeneratorTest.java | 118 -
.../storm/windowing/WindowManagerTest.java | 570 -
.../final-package/src/main/assembly/binary.xml | 9 +-
storm-dist/binary/pom.xml | 3 +-
storm-dist/binary/storm-client-bin/pom.xml | 65 +
.../src/main/assembly/storm-client.xml | 33 +
storm-dist/binary/storm-drpc-server-bin/pom.xml | 64 -
.../src/main/assembly/storm-drpc-server.xml | 32 -
storm-dist/binary/storm-webapp-bin/pom.xml | 64 +
.../src/main/assembly/storm-webapp.xml | 32 +
storm-drpc-server/pom.xml | 162 -
.../apache/storm/daemon/drpc/DRPCServer.java | 180 -
.../webapp/AuthorizationExceptionMapper.java | 39 -
.../daemon/drpc/webapp/DRPCApplication.java | 47 -
.../daemon/drpc/webapp/DRPCExceptionMapper.java | 61 -
.../storm/daemon/drpc/webapp/DRPCResource.java | 63 -
.../daemon/drpc/webapp/ReqContextFilter.java | 69 -
.../storm/daemon/drpc/DRPCServerTest.java | 214 -
storm-server/pom.xml | 157 +
.../java/org/apache/storm/DaemonConfig.java | 916 +
.../ILocalClusterTrackedTopologyAware.java | 54 +
.../java/org/apache/storm/LocalCluster.java | 834 +
.../main/java/org/apache/storm/LocalDRPC.java | 90 +
.../java/org/apache/storm/ProcessSimulator.java | 97 +
.../src/main/java/org/apache/storm/Testing.java | 716 +
.../storm/blobstore/BlobKeySequenceInfo.java | 40 +
.../apache/storm/blobstore/BlobStoreUtils.java | 270 +
.../storm/blobstore/BlobSynchronizer.java | 131 +
.../storm/blobstore/FileBlobStoreImpl.java | 269 +
.../storm/blobstore/KeySequenceNumber.java | 237 +
.../storm/blobstore/LocalFsBlobStore.java | 351 +
.../storm/blobstore/LocalFsBlobStoreFile.java | 159 +
.../container/ResourceIsolationInterface.java | 76 +
.../storm/container/cgroup/CgroupManager.java | 224 +
.../daemon/drpc/BlockingOutstandingRequest.java | 67 +
.../java/org/apache/storm/daemon/drpc/DRPC.java | 215 +
.../apache/storm/daemon/drpc/DRPCThrift.java | 58 +
.../storm/daemon/drpc/OutstandingRequest.java | 58 +
.../storm/daemon/drpc/RequestFactory.java | 24 +
.../storm/daemon/metrics/MetricsUtils.java | 109 +
.../reporters/ConsolePreparableReporter.java | 76 +
.../reporters/CsvPreparableReporter.java | 80 +
.../reporters/JmxPreparableReporter.java | 71 +
.../metrics/reporters/PreparableReporter.java | 32 +
.../org/apache/storm/daemon/nimbus/Nimbus.java | 3807 ++
.../storm/daemon/nimbus/TopologyActions.java | 31 +
.../storm/daemon/nimbus/TopologyResources.java | 63 +
.../daemon/nimbus/TopologyStateTransition.java | 27 +
.../storm/daemon/supervisor/BasicContainer.java | 723 +
.../supervisor/BasicContainerLauncher.java | 62 +
.../storm/daemon/supervisor/Container.java | 567 +
.../daemon/supervisor/ContainerLauncher.java | 106 +
.../supervisor/ContainerRecoveryException.java | 29 +
.../DefaultUncaughtExceptionHandler.java | 31 +
.../supervisor/EventManagerPushCallback.java | 37 +
.../storm/daemon/supervisor/Killable.java | 50 +
.../storm/daemon/supervisor/LocalContainer.java | 94 +
.../supervisor/LocalContainerLauncher.java | 60 +
.../daemon/supervisor/ReadClusterState.java | 358 +
.../daemon/supervisor/RunAsUserContainer.java | 101 +
.../supervisor/RunAsUserContainerLauncher.java | 60 +
.../apache/storm/daemon/supervisor/Slot.java | 787 +
.../daemon/supervisor/StandaloneSupervisor.java | 91 +
.../storm/daemon/supervisor/Supervisor.java | 362 +
.../daemon/supervisor/SupervisorUtils.java | 191 +
.../apache/storm/daemon/supervisor/UniFunc.java | 22 +
.../supervisor/timer/SupervisorHealthCheck.java | 41 +
.../supervisor/timer/SupervisorHeartbeat.java | 88 +
.../daemon/supervisor/timer/UpdateBlobs.java | 105 +
.../org/apache/storm/event/EventManager.java | 24 +
.../org/apache/storm/event/EventManagerImp.java | 100 +
.../apache/storm/healthcheck/HealthChecker.java | 122 +
.../apache/storm/localizer/AsyncLocalizer.java | 437 +
.../org/apache/storm/localizer/ILocalizer.java | 70 +
.../localizer/LocalDownloadedResource.java | 146 +
.../apache/storm/localizer/LocalResource.java | 44 +
.../storm/localizer/LocalizedResource.java | 130 +
.../LocalizedResourceRetentionSet.java | 140 +
.../storm/localizer/LocalizedResourceSet.java | 101 +
.../org/apache/storm/localizer/Localizer.java | 704 +
.../storm/logging/ThriftAccessLogger.java | 56 +
.../logging/filters/AccessLoggingFilter.java | 52 +
.../metric/ClusterMetricsConsumerExecutor.java | 89 +
.../metric/LoggingClusterMetricsConsumer.java | 86 +
.../storm/metric/StormMetricsRegistry.java | 88 +
.../org/apache/storm/metric/api/DataPoint.java | 43 +
.../metric/api/IClusterMetricsConsumer.java | 63 +
.../storm/nimbus/DefaultTopologyValidator.java | 31 +
.../org/apache/storm/nimbus/ILeaderElector.java | 73 +
.../nimbus/ITopologyActionNotifierPlugin.java | 43 +
.../apache/storm/nimbus/ITopologyValidator.java | 28 +
.../storm/pacemaker/IServerMessageHandler.java | 25 +
.../org/apache/storm/pacemaker/Pacemaker.java | 218 +
.../apache/storm/pacemaker/PacemakerServer.java | 169 +
.../pacemaker/codec/ThriftNettyServerCodec.java | 100 +
.../storm/scheduler/DefaultScheduler.java | 111 +
.../apache/storm/scheduler/EvenScheduler.java | 172 +
.../storm/scheduler/IsolationScheduler.java | 418 +
.../scheduler/multitenant/DefaultPool.java | 219 +
.../storm/scheduler/multitenant/FreePool.java | 125 +
.../scheduler/multitenant/IsolatedPool.java | 371 +
.../multitenant/MultitenantScheduler.java | 99 +
.../storm/scheduler/multitenant/Node.java | 340 +
.../storm/scheduler/multitenant/NodePool.java | 296 +
.../resource/ResourceAwareScheduler.java | 437 +
.../eviction/DefaultEvictionStrategy.java | 126 +
.../strategies/eviction/IEvictionStrategy.java | 42 +
.../DefaultSchedulingPriorityStrategy.java | 80 +
.../priority/ISchedulingPriorityStrategy.java | 36 +
.../storm/testing/CompleteTopologyParam.java | 103 +
.../storm/testing/InProcessZookeeper.java | 59 +
.../java/org/apache/storm/testing/TestJob.java | 43 +
.../apache/storm/testing/TrackedTopology.java | 135 +
.../storm/topology/ConfigurableTopology.java | 184 +
.../apache/storm/utils/BufferInputStream.java | 54 +
.../apache/storm/utils/ServerConfigUtils.java | 199 +
.../org/apache/storm/utils/ServerUtils.java | 772 +
.../storm/utils/StormCommonInstaller.java | 43 +
.../storm/zookeeper/LeaderElectorImp.java | 123 +
.../org/apache/storm/zookeeper/Zookeeper.java | 261 +
.../java/org/apache/storm/MessagingTest.java | 68 +
.../java/org/apache/storm/PacemakerTest.java | 242 +
.../test/java/org/apache/storm/TestCgroups.java | 129 +
.../apache/storm/TestDaemonConfigValidate.java | 110 +
.../java/org/apache/storm/TickTupleTest.java | 102 +
.../apache/storm/blobstore/BlobStoreTest.java | 469 +
.../storm/blobstore/BlobSynchronizerTest.java | 137 +
.../org/apache/storm/daemon/drpc/DRPCTest.java | 253 +
.../daemon/supervisor/BasicContainerTest.java | 486 +
.../storm/daemon/supervisor/ContainerTest.java | 270 +
.../storm/daemon/supervisor/SlotTest.java | 498 +
.../storm/localizer/AsyncLocalizerTest.java | 187 +
.../LocalizedResourceRetentionSetTest.java | 85 +
.../localizer/LocalizedResourceSetTest.java | 74 +
.../apache/storm/localizer/LocalizerTest.java | 679 +
.../ClusterMetricsConsumerExecutorTest.java | 133 +
.../apache/storm/nimbus/LocalNimbusTest.java | 132 +
.../resource/TestResourceAwareScheduler.java | 1367 +
.../storm/scheduler/resource/TestUser.java | 111 +
.../TestUtilsForResourceAwareScheduler.java | 369 +
.../eviction/TestDefaultEvictionStrategy.java | 752 +
.../TestDefaultResourceAwareStrategy.java | 332 +
.../src/test/resources/localizer/localtest.zip | Bin 0 -> 6378 bytes
.../localizer/localtestwithsymlink.jar | Bin 0 -> 6591 bytes
.../localizer/localtestwithsymlink.tar | Bin 0 -> 24576 bytes
.../localizer/localtestwithsymlink.tar.gz | Bin 0 -> 6106 bytes
.../localizer/localtestwithsymlink.tgz | Bin 0 -> 6106 bytes
storm-submit-tools/pom.xml | 4 +-
storm-webapp/pom.xml | 163 +
.../apache/storm/daemon/drpc/DRPCServer.java | 182 +
.../webapp/AuthorizationExceptionMapper.java | 39 +
.../daemon/drpc/webapp/DRPCApplication.java | 47 +
.../daemon/drpc/webapp/DRPCExceptionMapper.java | 61 +
.../storm/daemon/drpc/webapp/DRPCResource.java | 63 +
.../daemon/drpc/webapp/ReqContextFilter.java | 69 +
.../storm/daemon/drpc/DRPCServerTest.java | 214 +
2437 files changed, 266439 insertions(+), 265276 deletions(-)
----------------------------------------------------------------------