You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by pt...@apache.org on 2015/11/05 21:41:30 UTC
[51/60] [abbrv] [partial] storm git commit: Release 2.0.4-SNAPSHOT
Release 2.0.4-SNAPSHOT
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/e935da91
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/e935da91
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/e935da91
Branch: refs/heads/jstorm-import
Commit: e935da91a897797dad56e24c4ffa57860ac91878
Parents: ae1f5dd
Author: zhongyan.feng <zh...@alipay.com>
Authored: Wed Aug 5 20:11:20 2015 +0800
Committer: zhongyan.feng <zh...@alipay.com>
Committed: Wed Aug 5 20:11:20 2015 +0800
----------------------------------------------------------------------
LICENSE | 0
README.md | Bin
bin/check_jstorm_Supervisor.sh | 13 +
bin/jstorm.py | 459 +
bin/start.sh | 78 +
bin/stop.sh | 15 +
conf/cgconfig.conf | 18 +
conf/client_log4j.properties | 19 +
conf/client_logback.xml | 18 +
conf/jstorm.log4j.properties | 50 +
conf/jstorm.logback.xml | 84 +
conf/storm.yaml | 83 +
dev-tools/add_apache_license.sh | 1 +
dev-tools/java_license_header.txt | 17 +
dev-tools/py_license_header.txt | 18 +
dev-tools/storm-eclipse-java-formatter.xml | 291 +
docs/log.test.xlsx | Bin 0 -> 10428 bytes
example/sequence-split-merge/.classpath | 31 +
example/sequence-split-merge/.gitignore | 2 +
example/sequence-split-merge/.project | 23 +
.../.settings/org.eclipse.core.resources.prefs | 5 +
.../.settings/org.eclipse.jdt.core.prefs | 5 +
.../.settings/org.eclipse.m2e.core.prefs | 4 +
example/sequence-split-merge/conf/conf.prop | 0
example/sequence-split-merge/conf/conf.yaml | 0
example/sequence-split-merge/conf/topology.yaml | 0
example/sequence-split-merge/drpc.sh | 3 +
example/sequence-split-merge/pom.xml | 44 +-
.../alipay/dw/jstorm/example/IntervalCheck.java | 17 +
.../alipay/dw/jstorm/example/TpsCounter.java | 17 +
.../example/batch/SimpleBatchTopology.java | 78 +-
.../dw/jstorm/example/batch/SimpleBolt.java | 19 +-
.../dw/jstorm/example/batch/SimpleSpout.java | 17 +
.../dw/jstorm/example/drpc/ReachTopology.java | 41 +-
.../jstorm/example/drpc/TestReachTopology.java | 26 +-
.../example/sequence/SequenceTopology.java | 87 +-
.../example/sequence/SequenceTopologyDef.java | 17 +
.../example/sequence/SequenceTopologyTool.java | 17 +
.../sequence/SequenceTopologyUserDefine.java | 17 +
.../dw/jstorm/example/sequence/bean/Pair.java | 17 +
.../jstorm/example/sequence/bean/PairMaker.java | 17 +
.../example/sequence/bean/TradeCustomer.java | 17 +
.../example/sequence/bolt/MergeRecord.java | 17 +
.../jstorm/example/sequence/bolt/PairCount.java | 17 +
.../example/sequence/bolt/SplitRecord.java | 17 +
.../example/sequence/bolt/TotalCount.java | 72 +-
.../example/sequence/spout/SequenceSpout.java | 21 +-
.../transcation/TransactionalGlobalCount.java | 358 +-
example/sequence-split-merge/start.sh | 4 +-
history.md | 868 +-
history_cn.md | 77 +
jstorm-client-extension/pom.xml | 85 -
.../java/com/alibaba/jstorm/batch/BatchId.java | 66 -
.../jstorm/batch/BatchTopologyBuilder.java | 69 -
.../com/alibaba/jstorm/batch/IBatchSpout.java | 37 -
.../com/alibaba/jstorm/batch/ICommitter.java | 36 -
.../com/alibaba/jstorm/batch/IPostCommit.java | 14 -
.../alibaba/jstorm/batch/IPrepareCommit.java | 20 -
.../jstorm/batch/impl/BatchSpoutMsgId.java | 49 -
.../jstorm/batch/impl/BatchSpoutTrigger.java | 312 -
.../jstorm/batch/impl/CoordinatedBolt.java | 281 -
.../alibaba/jstorm/batch/util/BatchCommon.java | 65 -
.../com/alibaba/jstorm/batch/util/BatchDef.java | 26 -
.../alibaba/jstorm/batch/util/BatchStatus.java | 33 -
.../jstorm/callback/AsyncLoopDefaultKill.java | 25 -
.../jstorm/callback/AsyncLoopRunnable.java | 82 -
.../jstorm/callback/AsyncLoopThread.java | 122 -
.../alibaba/jstorm/callback/BaseCallback.java | 13 -
.../com/alibaba/jstorm/callback/Callback.java | 13 -
.../jstorm/callback/ClusterStateCallback.java | 7 -
.../jstorm/callback/DefaultWatcherCallBack.java | 26 -
.../jstorm/callback/RunnableCallback.java | 47 -
.../jstorm/callback/WatcherCallBack.java | 8 -
.../alibaba/jstorm/client/ConfigExtension.java | 642 -
.../alibaba/jstorm/client/WorkerAssignment.java | 264 -
.../jstorm/client/metric/MetricCallback.java | 7 -
.../jstorm/client/metric/MetricClient.java | 66 -
.../jstorm/client/spout/IAckValueSpout.java | 15 -
.../jstorm/client/spout/IFailValueSpout.java | 15 -
.../alibaba/jstorm/cluster/ClusterState.java | 38 -
.../jstorm/cluster/DistributedClusterState.java | 175 -
.../jstorm/common/stats/StatBuckets.java | 124 -
.../jstorm/common/stats/StaticsType.java | 5 -
.../alibaba/jstorm/metric/JStormHistogram.java | 39 -
.../com/alibaba/jstorm/metric/JStormTimer.java | 61 -
.../com/alibaba/jstorm/metric/MetricDef.java | 39 -
.../com/alibaba/jstorm/metric/MetricInfo.java | 27 -
.../com/alibaba/jstorm/metric/MetricJstack.java | 123 -
.../java/com/alibaba/jstorm/metric/Metrics.java | 330 -
.../alibaba/jstorm/metric/UserDefMetric.java | 106 -
.../jstorm/metric/UserDefMetricData.java | 138 -
.../jstorm/metric/metrdata/CounterData.java | 23 -
.../jstorm/metric/metrdata/GaugeData.java | 23 -
.../jstorm/metric/metrdata/HistogramData.java | 112 -
.../jstorm/metric/metrdata/MeterData.java | 58 -
.../jstorm/metric/metrdata/TimerData.java | 149 -
.../alibaba/jstorm/utils/DisruptorQueue.java | 151 -
.../com/alibaba/jstorm/utils/EventSampler.java | 100 -
.../alibaba/jstorm/utils/ExpiredCallback.java | 5 -
.../com/alibaba/jstorm/utils/FileAttribute.java | 118 -
.../alibaba/jstorm/utils/HttpserverUtils.java | 30 -
.../com/alibaba/jstorm/utils/IntervalCheck.java | 58 -
.../com/alibaba/jstorm/utils/JStormUtils.java | 1076 -
.../com/alibaba/jstorm/utils/NetWorkUtils.java | 120 -
.../alibaba/jstorm/utils/OlderFileFilter.java | 29 -
.../java/com/alibaba/jstorm/utils/Pair.java | 28 -
.../com/alibaba/jstorm/utils/PathUtils.java | 130 -
.../com/alibaba/jstorm/utils/RandomRange.java | 57 -
.../com/alibaba/jstorm/utils/RotatingMap.java | 133 -
.../com/alibaba/jstorm/utils/RunCounter.java | 85 -
.../com/alibaba/jstorm/utils/SmartThread.java | 18 -
.../com/alibaba/jstorm/utils/TimeCacheMap.java | 147 -
.../alibaba/jstorm/utils/TimeCacheQueue.java | 168 -
.../com/alibaba/jstorm/utils/TimeFormat.java | 199 -
.../com/alibaba/jstorm/utils/TimeOutMap.java | 18 -
.../com/alibaba/jstorm/utils/TimeUtils.java | 34 -
.../java/com/alibaba/jstorm/zk/Factory.java | 20 -
.../java/com/alibaba/jstorm/zk/ZkConstant.java | 19 -
.../com/alibaba/jstorm/zk/ZkCreateModes.java | 21 -
.../com/alibaba/jstorm/zk/ZkEventTypes.java | 27 -
.../com/alibaba/jstorm/zk/ZkKeeperStates.java | 24 -
.../main/java/com/alibaba/jstorm/zk/ZkTool.java | 201 -
.../java/com/alibaba/jstorm/zk/Zookeeper.java | 217 -
jstorm-client/pom.xml | 194 -
.../src/main/java/backtype/storm/Config.java | 1382 -
.../java/backtype/storm/ConfigValidation.java | 100 -
.../src/main/java/backtype/storm/Constants.java | 20 -
.../backtype/storm/GenericOptionsParser.java | 296 -
.../main/java/backtype/storm/ILocalCluster.java | 46 -
.../main/java/backtype/storm/ILocalDRPC.java | 10 -
.../java/backtype/storm/StormSubmitter.java | 375 -
.../src/main/java/backtype/storm/Tool.java | 47 -
.../main/java/backtype/storm/ToolRunner.java | 53 -
.../backtype/storm/clojure/ClojureBolt.java | 108 -
.../backtype/storm/clojure/ClojureSpout.java | 142 -
.../backtype/storm/clojure/RichShellBolt.java | 36 -
.../backtype/storm/clojure/RichShellSpout.java | 36 -
.../java/backtype/storm/command/activate.java | 49 -
.../backtype/storm/command/config_value.java | 33 -
.../java/backtype/storm/command/deactivate.java | 49 -
.../backtype/storm/command/kill_topology.java | 61 -
.../main/java/backtype/storm/command/list.java | 59 -
.../backtype/storm/command/metrics_monitor.java | 56 -
.../java/backtype/storm/command/rebalance.java | 60 -
.../java/backtype/storm/command/restart.java | 120 -
.../storm/coordination/BatchBoltExecutor.java | 92 -
.../coordination/BatchOutputCollector.java | 31 -
.../coordination/BatchOutputCollectorImpl.java | 36 -
.../coordination/BatchSubtopologyBuilder.java | 469 -
.../storm/coordination/CoordinatedBolt.java | 379 -
.../backtype/storm/coordination/IBatchBolt.java | 16 -
.../backtype/storm/daemon/Shutdownable.java | 5 -
.../storm/drpc/DRPCInvocationsClient.java | 78 -
.../java/backtype/storm/drpc/DRPCSpout.java | 162 -
.../java/backtype/storm/drpc/JoinResult.java | 59 -
.../java/backtype/storm/drpc/KeyedFairBolt.java | 75 -
.../storm/drpc/LinearDRPCInputDeclarer.java | 42 -
.../storm/drpc/LinearDRPCTopologyBuilder.java | 378 -
.../backtype/storm/drpc/PrepareRequest.java | 41 -
.../java/backtype/storm/drpc/ReturnResults.java | 83 -
.../storm/generated/AlreadyAliveException.java | 328 -
.../storm/generated/AuthorizationException.java | 328 -
.../java/backtype/storm/generated/Bolt.java | 427 -
.../backtype/storm/generated/BoltStats.java | 1111 -
.../storm/generated/ClusterSummary.java | 693 -
.../storm/generated/ComponentCommon.java | 707 -
.../storm/generated/ComponentObject.java | 385 -
.../storm/generated/DRPCExecutionException.java | 328 -
.../backtype/storm/generated/DRPCRequest.java | 425 -
.../storm/generated/DistributedRPC.java | 964 -
.../generated/DistributedRPCInvocations.java | 2015 --
.../backtype/storm/generated/ErrorInfo.java | 425 -
.../backtype/storm/generated/ExecutorInfo.java | 420 -
.../storm/generated/ExecutorSpecificStats.java | 318 -
.../storm/generated/GlobalStreamId.java | 425 -
.../java/backtype/storm/generated/Grouping.java | 714 -
.../generated/InvalidTopologyException.java | 328 -
.../backtype/storm/generated/JavaObject.java | 463 -
.../backtype/storm/generated/JavaObjectArg.java | 532 -
.../backtype/storm/generated/KillOptions.java | 320 -
.../storm/generated/MonitorOptions.java | 320 -
.../java/backtype/storm/generated/Nimbus.java | 18351 -----------
.../storm/generated/NotAliveException.java | 328 -
.../backtype/storm/generated/NullStruct.java | 225 -
.../storm/generated/RebalanceOptions.java | 409 -
.../storm/generated/ShellComponent.java | 417 -
.../backtype/storm/generated/SpoutSpec.java | 427 -
.../backtype/storm/generated/SpoutStats.java | 756 -
.../storm/generated/StateSpoutSpec.java | 427 -
.../backtype/storm/generated/StormTopology.java | 660 -
.../backtype/storm/generated/StreamInfo.java | 462 -
.../backtype/storm/generated/SubmitOptions.java | 340 -
.../storm/generated/SupervisorSummary.java | 706 -
.../storm/generated/SupervisorWorkers.java | 464 -
.../storm/generated/TaskMetricData.java | 1135 -
.../backtype/storm/generated/TaskStats.java | 1285 -
.../backtype/storm/generated/TaskSummary.java | 1122 -
.../storm/generated/ThriftResourceType.java | 47 -
.../generated/TopologyAssignException.java | 328 -
.../backtype/storm/generated/TopologyInfo.java | 1022 -
.../storm/generated/TopologyInitialStatus.java | 44 -
.../storm/generated/TopologyMetricInfo.java | 594 -
.../storm/generated/TopologySummary.java | 900 -
.../backtype/storm/generated/UserDefMetric.java | 522 -
.../storm/generated/WorkerMetricData.java | 1135 -
.../backtype/storm/generated/WorkerSummary.java | 560 -
.../storm/grouping/CustomStreamGrouping.java | 29 -
.../java/backtype/storm/hooks/BaseTaskHook.java | 44 -
.../java/backtype/storm/hooks/ITaskHook.java | 28 -
.../backtype/storm/hooks/info/BoltAckInfo.java | 15 -
.../storm/hooks/info/BoltExecuteInfo.java | 16 -
.../backtype/storm/hooks/info/BoltFailInfo.java | 15 -
.../backtype/storm/hooks/info/EmitInfo.java | 19 -
.../backtype/storm/hooks/info/SpoutAckInfo.java | 14 -
.../storm/hooks/info/SpoutFailInfo.java | 13 -
.../backtype/storm/messaging/IConnection.java | 36 -
.../java/backtype/storm/messaging/IContext.java | 58 -
.../backtype/storm/messaging/TaskMessage.java | 51 -
.../storm/messaging/TransportFactory.java | 54 -
.../storm/metric/LoggingMetricsConsumer.java | 59 -
.../storm/metric/MetricsConsumerBolt.java | 56 -
.../java/backtype/storm/metric/SystemBolt.java | 157 -
.../storm/metric/api/AssignableMetric.java | 17 -
.../storm/metric/api/CombinedMetric.java | 21 -
.../backtype/storm/metric/api/CountMetric.java | 24 -
.../backtype/storm/metric/api/ICombiner.java | 7 -
.../java/backtype/storm/metric/api/IMetric.java | 5 -
.../storm/metric/api/IMetricsConsumer.java | 56 -
.../backtype/storm/metric/api/IReducer.java | 9 -
.../storm/metric/api/IStatefulObject.java | 5 -
.../backtype/storm/metric/api/MeanReducer.java | 39 -
.../storm/metric/api/MultiCountMetric.java | 28 -
.../storm/metric/api/MultiReducedMetric.java | 33 -
.../storm/metric/api/ReducedMetric.java | 21 -
.../backtype/storm/metric/api/StateMetric.java | 14 -
.../metric/api/rpc/AssignableShellMetric.java | 30 -
.../metric/api/rpc/CombinedShellMetric.java | 31 -
.../storm/metric/api/rpc/CountShellMetric.java | 38 -
.../storm/metric/api/rpc/IShellMetric.java | 31 -
.../metric/api/rpc/ReducedShellMetric.java | 32 -
.../java/backtype/storm/multilang/BoltMsg.java | 80 -
.../backtype/storm/multilang/ISerializer.java | 82 -
.../storm/multilang/JsonSerializer.java | 202 -
.../storm/multilang/NoOutputException.java | 40 -
.../java/backtype/storm/multilang/ShellMsg.java | 185 -
.../java/backtype/storm/multilang/SpoutMsg.java | 51 -
.../storm/nimbus/DefaultTopologyValidator.java | 16 -
.../storm/nimbus/ITopologyValidator.java | 12 -
.../backtype/storm/planner/CompoundSpout.java | 7 -
.../backtype/storm/planner/CompoundTask.java | 7 -
.../java/backtype/storm/planner/TaskBundle.java | 15 -
.../java/backtype/storm/scheduler/Cluster.java | 448 -
.../storm/scheduler/ExecutorDetails.java | 38 -
.../java/backtype/storm/scheduler/INimbus.java | 28 -
.../backtype/storm/scheduler/IScheduler.java | 27 -
.../backtype/storm/scheduler/ISupervisor.java | 33 -
.../storm/scheduler/SchedulerAssignment.java | 45 -
.../scheduler/SchedulerAssignmentImpl.java | 98 -
.../storm/scheduler/SupervisorDetails.java | 73 -
.../backtype/storm/scheduler/Topologies.java | 42 -
.../storm/scheduler/TopologyDetails.java | 76 -
.../backtype/storm/scheduler/WorkerSlot.java | 87 -
.../backtype/storm/security/auth/AuthUtils.java | 94 -
.../storm/security/auth/IAuthorizer.java | 38 -
.../storm/security/auth/ITransportPlugin.java | 49 -
.../storm/security/auth/ReqContext.java | 91 -
.../security/auth/SaslTransportPlugin.java | 150 -
.../security/auth/SimpleTransportPlugin.java | 119 -
.../storm/security/auth/ThriftClient.java | 138 -
.../storm/security/auth/ThriftServer.java | 70 -
.../auth/authorizer/DenyAuthorizer.java | 52 -
.../auth/authorizer/NoopAuthorizer.java | 53 -
.../auth/digest/ClientCallbackHandler.java | 101 -
.../auth/digest/DigestSaslTransportPlugin.java | 52 -
.../auth/digest/ServerCallbackHandler.java | 109 -
.../serialization/BlowfishTupleSerializer.java | 80 -
.../storm/serialization/DefaultKryoFactory.java | 47 -
.../storm/serialization/IKryoDecorator.java | 7 -
.../storm/serialization/IKryoFactory.java | 25 -
.../storm/serialization/ITupleDeserializer.java | 9 -
.../storm/serialization/ITupleSerializer.java | 15 -
.../serialization/KryoTupleDeserializer.java | 90 -
.../serialization/KryoTupleSerializer.java | 67 -
.../serialization/KryoValuesDeserializer.java | 39 -
.../serialization/KryoValuesSerializer.java | 45 -
.../serialization/SerializableSerializer.java | 46 -
.../serialization/SerializationFactory.java | 242 -
.../types/ArrayListSerializer.java | 14 -
.../serialization/types/HashMapSerializer.java | 14 -
.../serialization/types/HashSetSerializer.java | 14 -
.../types/ListDelegateSerializer.java | 14 -
.../storm/spout/IMultiSchemableSpout.java | 7 -
.../backtype/storm/spout/ISchemableSpout.java | 7 -
.../main/java/backtype/storm/spout/ISpout.java | 116 -
.../storm/spout/ISpoutOutputCollector.java | 15 -
.../storm/spout/ISpoutWaitStrategy.java | 18 -
.../java/backtype/storm/spout/MultiScheme.java | 12 -
.../storm/spout/NothingEmptyEmitStrategy.java | 14 -
.../backtype/storm/spout/RawMultiScheme.java | 20 -
.../java/backtype/storm/spout/RawScheme.java | 15 -
.../main/java/backtype/storm/spout/Scheme.java | 11 -
.../storm/spout/SchemeAsMultiScheme.java | 28 -
.../java/backtype/storm/spout/ShellSpout.java | 260 -
.../storm/spout/SleepSpoutWaitStrategy.java | 25 -
.../storm/spout/SpoutOutputCollector.java | 125 -
.../java/backtype/storm/state/IStateSpout.java | 15 -
.../storm/state/IStateSpoutOutputCollector.java | 5 -
.../backtype/storm/state/ISubscribedState.java | 9 -
.../state/ISynchronizeOutputCollector.java | 7 -
.../storm/state/StateSpoutOutputCollector.java | 11 -
.../storm/state/SynchronizeOutputCollector.java | 12 -
.../storm/task/GeneralTopologyContext.java | 206 -
.../main/java/backtype/storm/task/IBolt.java | 98 -
.../backtype/storm/task/IErrorReporter.java | 5 -
.../backtype/storm/task/IMetricsContext.java | 18 -
.../backtype/storm/task/IOutputCollector.java | 20 -
.../backtype/storm/task/OutputCollector.java | 245 -
.../java/backtype/storm/task/ShellBolt.java | 383 -
.../backtype/storm/task/TopologyContext.java | 317 -
.../storm/task/WorkerTopologyContext.java | 84 -
.../backtype/storm/testing/AckFailDelegate.java | 9 -
.../storm/testing/AckFailMapTracker.java | 35 -
.../java/backtype/storm/testing/AckTracker.java | 35 -
.../backtype/storm/testing/BatchNumberList.java | 55 -
.../storm/testing/BatchProcessWord.java | 23 -
.../backtype/storm/testing/BatchRepeatA.java | 30 -
.../backtype/storm/testing/BoltTracker.java | 24 -
.../storm/testing/CompleteTopologyParam.java | 57 -
.../storm/testing/CountingBatchBolt.java | 39 -
.../storm/testing/CountingCommitBolt.java | 42 -
.../backtype/storm/testing/FeederSpout.java | 83 -
.../java/backtype/storm/testing/FixedTuple.java | 25 -
.../backtype/storm/testing/FixedTupleSpout.java | 164 -
.../backtype/storm/testing/IdentityBolt.java | 25 -
.../storm/testing/KeyedCountingBatchBolt.java | 45 -
.../testing/KeyedCountingCommitterBolt.java | 8 -
.../storm/testing/KeyedSummingBatchBolt.java | 45 -
.../storm/testing/MemoryTransactionalSpout.java | 187 -
.../testing/MemoryTransactionalSpoutMeta.java | 21 -
.../backtype/storm/testing/MkClusterParam.java | 46 -
.../backtype/storm/testing/MkTupleParam.java | 37 -
.../backtype/storm/testing/MockedSources.java | 46 -
.../java/backtype/storm/testing/NGrouping.java | 34 -
.../storm/testing/NonRichBoltTracker.java | 34 -
.../testing/OpaqueMemoryTransactionalSpout.java | 190 -
.../storm/testing/PrepareBatchBolt.java | 33 -
.../backtype/storm/testing/SpoutTracker.java | 88 -
.../storm/testing/TestAggregatesCounter.java | 46 -
.../backtype/storm/testing/TestConfBolt.java | 44 -
.../backtype/storm/testing/TestGlobalCount.java | 43 -
.../java/backtype/storm/testing/TestJob.java | 24 -
.../storm/testing/TestKryoDecorator.java | 14 -
.../backtype/storm/testing/TestPlannerBolt.java | 28 -
.../storm/testing/TestPlannerSpout.java | 67 -
.../backtype/storm/testing/TestSerObject.java | 40 -
.../backtype/storm/testing/TestWordCounter.java | 43 -
.../backtype/storm/testing/TestWordSpout.java | 70 -
.../backtype/storm/testing/TrackedTopology.java | 17 -
.../storm/testing/TupleCaptureBolt.java | 68 -
.../topology/BaseConfigurationDeclarer.java | 41 -
.../storm/topology/BasicBoltExecutor.java | 50 -
.../storm/topology/BasicOutputCollector.java | 44 -
.../backtype/storm/topology/BoltDeclarer.java | 6 -
.../ComponentConfigurationDeclarer.java | 18 -
.../storm/topology/FailedException.java | 19 -
.../backtype/storm/topology/IBasicBolt.java | 20 -
.../storm/topology/IBasicOutputCollector.java | 11 -
.../backtype/storm/topology/IComponent.java | 30 -
.../java/backtype/storm/topology/IRichBolt.java | 12 -
.../backtype/storm/topology/IRichSpout.java | 12 -
.../storm/topology/IRichStateSpout.java | 7 -
.../backtype/storm/topology/InputDeclarer.java | 48 -
.../storm/topology/OutputFieldsDeclarer.java | 16 -
.../storm/topology/OutputFieldsGetter.java | 36 -
.../storm/topology/ReportedFailedException.java | 19 -
.../backtype/storm/topology/SpoutDeclarer.java | 6 -
.../storm/topology/TopologyBuilder.java | 424 -
.../storm/topology/base/BaseBasicBolt.java | 16 -
.../storm/topology/base/BaseBatchBolt.java | 9 -
.../storm/topology/base/BaseComponent.java | 11 -
...BaseOpaquePartitionedTransactionalSpout.java | 8 -
.../base/BasePartitionedTransactionalSpout.java | 9 -
.../storm/topology/base/BaseRichBolt.java | 9 -
.../storm/topology/base/BaseRichSpout.java | 33 -
.../topology/base/BaseTransactionalBolt.java | 8 -
.../topology/base/BaseTransactionalSpout.java | 9 -
.../storm/transactional/ICommitter.java | 9 -
.../ICommitterTransactionalSpout.java | 13 -
.../transactional/ITransactionalSpout.java | 88 -
.../storm/transactional/TransactionAttempt.java | 44 -
.../TransactionalSpoutBatchExecutor.java | 84 -
.../TransactionalSpoutCoordinator.java | 220 -
.../TransactionalTopologyBuilder.java | 566 -
.../IOpaquePartitionedTransactionalSpout.java | 46 -
.../IPartitionedTransactionalSpout.java | 60 -
...uePartitionedTransactionalSpoutExecutor.java | 153 -
.../PartitionedTransactionalSpoutExecutor.java | 136 -
.../state/RotatingTransactionalState.java | 143 -
.../transactional/state/TransactionalState.java | 132 -
.../main/java/backtype/storm/tuple/Fields.java | 82 -
.../main/java/backtype/storm/tuple/ITuple.java | 119 -
.../java/backtype/storm/tuple/MessageId.java | 86 -
.../main/java/backtype/storm/tuple/Tuple.java | 43 -
.../java/backtype/storm/tuple/TupleExt.java | 12 -
.../java/backtype/storm/tuple/TupleImpl.java | 342 -
.../java/backtype/storm/tuple/TupleImplExt.java | 31 -
.../main/java/backtype/storm/tuple/Values.java | 20 -
.../storm/utils/BufferFileInputStream.java | 37 -
.../backtype/storm/utils/CRC32OutputStream.java | 27 -
.../backtype/storm/utils/ClojureTimerTask.java | 18 -
.../java/backtype/storm/utils/Container.java | 7 -
.../java/backtype/storm/utils/DRPCClient.java | 70 -
.../backtype/storm/utils/DisruptorQueue.java | 71 -
.../storm/utils/DisruptorQueueImpl.java | 298 -
.../storm/utils/DisruptorWrapBlockingQueue.java | 192 -
.../storm/utils/IndifferentAccessMap.java | 169 -
.../backtype/storm/utils/InprocMessaging.java | 42 -
.../storm/utils/KeyedRoundRobinQueue.java | 51 -
.../java/backtype/storm/utils/ListDelegate.java | 139 -
.../java/backtype/storm/utils/LocalState.java | 78 -
.../java/backtype/storm/utils/MutableInt.java | 26 -
.../java/backtype/storm/utils/MutableLong.java | 26 -
.../backtype/storm/utils/MutableObject.java | 21 -
.../java/backtype/storm/utils/NimbusClient.java | 48 -
.../storm/utils/RegisteredGlobalState.java | 47 -
.../java/backtype/storm/utils/RotatingMap.java | 109 -
.../backtype/storm/utils/ServiceRegistry.java | 30 -
.../java/backtype/storm/utils/ShellProcess.java | 182 -
.../storm/utils/ThreadResourceManager.java | 28 -
.../storm/utils/ThriftTopologyUtils.java | 59 -
.../main/java/backtype/storm/utils/Time.java | 93 -
.../java/backtype/storm/utils/TimeCacheMap.java | 143 -
.../java/backtype/storm/utils/TupleHelpers.java | 16 -
.../main/java/backtype/storm/utils/Utils.java | 592 -
.../backtype/storm/utils/VersionedStore.java | 178 -
.../storm/utils/WindowedTimeThrottler.java | 35 -
.../backtype/storm/utils/WorkerClassLoader.java | 156 -
.../backtype/storm/utils/WritableUtils.java | 377 -
.../backtype/storm/utils/ZookeeperAuthInfo.java | 30 -
.../utils/disruptor/AbstractSequencerExt.java | 21 -
.../utils/disruptor/MultiProducerSequencer.java | 298 -
.../storm/utils/disruptor/RingBuffer.java | 1184 -
.../disruptor/SingleProducerSequencer.java | 199 -
.../src/main/java/storm/trident/JoinType.java | 13 -
.../src/main/java/storm/trident/Stream.java | 360 -
.../main/java/storm/trident/TridentState.java | 23 -
.../java/storm/trident/TridentTopology.java | 796 -
.../trident/drpc/ReturnResultsReducer.java | 96 -
.../fluent/ChainedAggregatorDeclarer.java | 166 -
.../fluent/ChainedFullAggregatorDeclarer.java | 15 -
.../ChainedPartitionAggregatorDeclarer.java | 15 -
.../trident/fluent/GlobalAggregationScheme.java | 9 -
.../storm/trident/fluent/GroupedStream.java | 157 -
.../trident/fluent/IAggregatableStream.java | 14 -
.../fluent/IChainedAggregatorDeclarer.java | 7 -
.../java/storm/trident/fluent/UniqueIdGen.java | 17 -
.../java/storm/trident/graph/GraphGrouper.java | 106 -
.../main/java/storm/trident/graph/Group.java | 89 -
.../storm/trident/operation/Aggregator.java | 9 -
.../java/storm/trident/operation/Assembly.java | 8 -
.../storm/trident/operation/BaseAggregator.java | 6 -
.../storm/trident/operation/BaseFilter.java | 6 -
.../storm/trident/operation/BaseFunction.java | 6 -
.../trident/operation/BaseMultiReducer.java | 16 -
.../storm/trident/operation/BaseOperation.java | 15 -
.../trident/operation/CombinerAggregator.java | 12 -
.../storm/trident/operation/EachOperation.java | 5 -
.../java/storm/trident/operation/Filter.java | 8 -
.../java/storm/trident/operation/Function.java | 7 -
.../trident/operation/GroupedMultiReducer.java | 14 -
.../storm/trident/operation/MultiReducer.java | 14 -
.../java/storm/trident/operation/Operation.java | 9 -
.../trident/operation/ReducerAggregator.java | 9 -
.../trident/operation/TridentCollector.java | 9 -
.../operation/TridentMultiReducerContext.java | 19 -
.../operation/TridentOperationContext.java | 48 -
.../storm/trident/operation/builtin/Count.java | 24 -
.../storm/trident/operation/builtin/Debug.java | 22 -
.../storm/trident/operation/builtin/Equals.java | 26 -
.../trident/operation/builtin/FilterNull.java | 14 -
.../storm/trident/operation/builtin/FirstN.java | 108 -
.../storm/trident/operation/builtin/MapGet.java | 21 -
.../storm/trident/operation/builtin/Negate.java | 31 -
.../trident/operation/builtin/SnapshotGet.java | 27 -
.../storm/trident/operation/builtin/Sum.java | 25 -
.../operation/builtin/TupleCollectionGet.java | 29 -
.../operation/impl/CaptureCollector.java | 25 -
.../operation/impl/ChainedAggregatorImpl.java | 96 -
.../trident/operation/impl/ChainedResult.java | 36 -
.../operation/impl/CombinerAggStateUpdater.java | 39 -
.../impl/CombinerAggregatorCombineImpl.java | 44 -
.../impl/CombinerAggregatorInitImpl.java | 32 -
.../trident/operation/impl/FilterExecutor.java | 36 -
.../operation/impl/GlobalBatchToPartition.java | 12 -
.../trident/operation/impl/GroupCollector.java | 31 -
.../operation/impl/GroupedAggregator.java | 79 -
.../impl/GroupedMultiReducerExecutor.java | 78 -
.../operation/impl/IdentityMultiReducer.java | 34 -
.../impl/IndexHashBatchToPartition.java | 12 -
.../operation/impl/JoinerMultiReducer.java | 142 -
.../operation/impl/ReducerAggStateUpdater.java | 36 -
.../operation/impl/ReducerAggregatorImpl.java | 39 -
.../storm/trident/operation/impl/Result.java | 10 -
.../operation/impl/SingleEmitAggregator.java | 78 -
.../trident/operation/impl/TrueFilter.java | 23 -
.../storm/trident/partition/GlobalGrouping.java | 28 -
.../trident/partition/IdentityGrouping.java | 44 -
.../trident/partition/IndexHashGrouping.java | 36 -
.../storm/trident/planner/BridgeReceiver.java | 21 -
.../main/java/storm/trident/planner/Node.java | 63 -
.../storm/trident/planner/NodeStateInfo.java | 14 -
.../storm/trident/planner/PartitionNode.java | 35 -
.../storm/trident/planner/ProcessorContext.java | 12 -
.../storm/trident/planner/ProcessorNode.java | 16 -
.../java/storm/trident/planner/SpoutNode.java | 22 -
.../storm/trident/planner/SubtopologyBolt.java | 201 -
.../storm/trident/planner/TridentProcessor.java | 23 -
.../storm/trident/planner/TupleReceiver.java | 10 -
.../planner/processor/AggregateProcessor.java | 67 -
.../planner/processor/AppendCollector.java | 45 -
.../planner/processor/EachProcessor.java | 63 -
.../planner/processor/FreshCollector.java | 42 -
.../processor/MultiReducerProcessor.java | 76 -
.../processor/PartitionPersistProcessor.java | 90 -
.../planner/processor/ProjectedProcessor.java | 56 -
.../planner/processor/StateQueryProcessor.java | 89 -
.../planner/processor/TridentContext.java | 59 -
.../storm/trident/spout/BatchSpoutExecutor.java | 75 -
.../main/java/storm/trident/spout/IBatchID.java | 7 -
.../java/storm/trident/spout/IBatchSpout.java | 16 -
.../trident/spout/ICommitterTridentSpout.java | 14 -
.../spout/IOpaquePartitionedTridentSpout.java | 45 -
.../trident/spout/IPartitionedTridentSpout.java | 60 -
.../storm/trident/spout/ISpoutPartition.java | 8 -
.../java/storm/trident/spout/ITridentSpout.java | 77 -
.../OpaquePartitionedTridentSpoutExecutor.java | 184 -
.../spout/PartitionedTridentSpoutExecutor.java | 154 -
.../trident/spout/RichSpoutBatchExecutor.java | 181 -
.../storm/trident/spout/RichSpoutBatchId.java | 32 -
.../spout/RichSpoutBatchIdSerializer.java | 21 -
.../trident/spout/RichSpoutBatchTriggerer.java | 161 -
.../trident/spout/TridentSpoutCoordinator.java | 78 -
.../trident/spout/TridentSpoutExecutor.java | 120 -
.../storm/trident/state/BaseQueryFunction.java | 8 -
.../storm/trident/state/BaseStateUpdater.java | 8 -
.../trident/state/CombinerValueUpdater.java | 19 -
.../storm/trident/state/ITupleCollection.java | 9 -
.../state/JSONNonTransactionalSerializer.java | 28 -
.../trident/state/JSONOpaqueSerializer.java | 36 -
.../state/JSONTransactionalSerializer.java | 34 -
.../java/storm/trident/state/OpaqueValue.java | 58 -
.../java/storm/trident/state/QueryFunction.java | 11 -
.../java/storm/trident/state/ReadOnlyState.java | 14 -
.../trident/state/ReducerValueUpdater.java | 24 -
.../java/storm/trident/state/Serializer.java | 9 -
.../main/java/storm/trident/state/State.java | 22 -
.../java/storm/trident/state/StateFactory.java | 9 -
.../java/storm/trident/state/StateSpec.java | 13 -
.../java/storm/trident/state/StateType.java | 8 -
.../java/storm/trident/state/StateUpdater.java | 16 -
.../storm/trident/state/TransactionalValue.java | 27 -
.../java/storm/trident/state/ValueUpdater.java | 6 -
.../trident/state/map/CachedBatchReadsMap.java | 63 -
.../java/storm/trident/state/map/CachedMap.java | 62 -
.../storm/trident/state/map/IBackingMap.java | 9 -
.../state/map/MapCombinerAggStateUpdater.java | 66 -
.../state/map/MapReducerAggStateUpdater.java | 75 -
.../java/storm/trident/state/map/MapState.java | 9 -
.../state/map/MicroBatchIBackingMap.java | 68 -
.../trident/state/map/NonTransactionalMap.java | 50 -
.../java/storm/trident/state/map/OpaqueMap.java | 107 -
.../trident/state/map/ReadOnlyMapState.java | 9 -
.../trident/state/map/RemovableMapState.java | 8 -
.../trident/state/map/SnapshottableMap.java | 59 -
.../trident/state/map/TransactionalMap.java | 92 -
.../state/snapshot/ReadOnlySnapshottable.java | 7 -
.../trident/state/snapshot/Snapshottable.java | 10 -
.../trident/testing/CountAsAggregator.java | 30 -
.../storm/trident/testing/FeederBatchSpout.java | 168 -
.../testing/FeederCommitterBatchSpout.java | 79 -
.../storm/trident/testing/FixedBatchSpout.java | 80 -
.../java/storm/trident/testing/IFeeder.java | 6 -
.../trident/testing/LRUMemoryMapState.java | 135 -
.../storm/trident/testing/MemoryBackingMap.java | 30 -
.../storm/trident/testing/MemoryMapState.java | 157 -
.../main/java/storm/trident/testing/Split.java | 19 -
.../storm/trident/testing/StringLength.java | 15 -
.../java/storm/trident/testing/TrueFilter.java | 13 -
.../java/storm/trident/testing/TuplifyArgs.java | 21 -
.../java/storm/trident/topology/BatchInfo.java | 16 -
.../trident/topology/ITridentBatchBolt.java | 15 -
.../topology/MasterBatchCoordinator.java | 317 -
.../trident/topology/TransactionAttempt.java | 49 -
.../trident/topology/TridentBoltExecutor.java | 430 -
.../topology/TridentTopologyBuilder.java | 751 -
.../state/RotatingTransactionalState.java | 130 -
.../topology/state/TransactionalState.java | 119 -
.../java/storm/trident/tuple/ComboList.java | 75 -
.../main/java/storm/trident/tuple/ConsList.java | 27 -
.../java/storm/trident/tuple/TridentTuple.java | 17 -
.../storm/trident/tuple/TridentTupleView.java | 342 -
.../java/storm/trident/tuple/ValuePointer.java | 43 -
.../storm/trident/util/ErrorEdgeFactory.java | 11 -
.../java/storm/trident/util/IndexedEdge.java | 55 -
.../main/java/storm/trident/util/LRUMap.java | 18 -
.../java/storm/trident/util/TridentUtils.java | 125 -
jstorm-client/src/main/py/__init__.py | 0
.../src/main/py/storm/DistributedRPC-remote | 85 -
.../src/main/py/storm/DistributedRPC.py | 256 -
.../py/storm/DistributedRPCInvocations-remote | 99 -
.../main/py/storm/DistributedRPCInvocations.py | 549 -
jstorm-client/src/main/py/storm/Nimbus-remote | 232 -
jstorm-client/src/main/py/storm/Nimbus.py | 4149 ---
jstorm-client/src/main/py/storm/__init__.py | 1 -
jstorm-client/src/main/py/storm/constants.py | 9 -
jstorm-client/src/main/py/storm/ttypes.py | 4254 ---
.../jstorm/util/queue/DisruptorTest.java | 545 -
jstorm-core/.classpath | 37 +
jstorm-core/.gitignore | 1 +
jstorm-core/.project | 36 +
.../.settings/org.eclipse.core.resources.prefs | 6 +
.../.settings/org.eclipse.jdt.core.prefs | 8 +
.../.settings/org.eclipse.m2e.core.prefs | 4 +
.../.settings/org.eclipse.wst.common.component | 6 +
...rg.eclipse.wst.common.project.facet.core.xml | 5 +
.../.settings/org.eclipse.wst.validation.prefs | 2 +
jstorm-core/pom.xml | 254 +
.../src/main/java/backtype/storm/Config.java | 1579 +
.../java/backtype/storm/ConfigValidation.java | 351 +
.../src/main/java/backtype/storm/Constants.java | 37 +
.../backtype/storm/GenericOptionsParser.java | 283 +
.../backtype/storm/ICredentialsListener.java | 32 +
.../main/java/backtype/storm/ILocalCluster.java | 49 +
.../main/java/backtype/storm/ILocalDRPC.java | 27 +
.../main/java/backtype/storm/LocalCluster.java | 275 +
.../java/backtype/storm/LocalClusterMap.java | 126 +
.../src/main/java/backtype/storm/LocalDRPC.java | 100 +
.../main/java/backtype/storm/LocalUtils.java | 127 +
.../java/backtype/storm/StormSubmitter.java | 366 +
.../src/main/java/backtype/storm/Tool.java | 71 +
.../main/java/backtype/storm/ToolRunner.java | 69 +
.../backtype/storm/clojure/ClojureBolt.java | 119 +
.../backtype/storm/clojure/ClojureSpout.java | 153 +
.../backtype/storm/clojure/RichShellBolt.java | 51 +
.../backtype/storm/clojure/RichShellSpout.java | 51 +
.../java/backtype/storm/command/activate.java | 65 +
.../backtype/storm/command/config_value.java | 50 +
.../java/backtype/storm/command/deactivate.java | 65 +
.../backtype/storm/command/kill_topology.java | 77 +
.../main/java/backtype/storm/command/list.java | 70 +
.../backtype/storm/command/metrics_monitor.java | 72 +
.../java/backtype/storm/command/rebalance.java | 127 +
.../java/backtype/storm/command/restart.java | 80 +
.../backtype/storm/command/update_config.java | 69 +
.../storm/coordination/BatchBoltExecutor.java | 108 +
.../coordination/BatchOutputCollector.java | 46 +
.../coordination/BatchOutputCollectorImpl.java | 53 +
.../coordination/BatchSubtopologyBuilder.java | 479 +
.../storm/coordination/CoordinatedBolt.java | 382 +
.../backtype/storm/coordination/IBatchBolt.java | 30 +
.../backtype/storm/daemon/Shutdownable.java | 22 +
.../storm/drpc/DRPCInvocationsClient.java | 114 +
.../java/backtype/storm/drpc/DRPCSpout.java | 263 +
.../java/backtype/storm/drpc/JoinResult.java | 75 +
.../java/backtype/storm/drpc/KeyedFairBolt.java | 93 +
.../storm/drpc/LinearDRPCInputDeclarer.java | 52 +
.../storm/drpc/LinearDRPCTopologyBuilder.java | 394 +
.../backtype/storm/drpc/PrepareRequest.java | 59 +
.../java/backtype/storm/drpc/ReturnResults.java | 125 +
.../storm/generated/AlreadyAliveException.java | 389 +
.../storm/generated/AuthorizationException.java | 389 +
.../java/backtype/storm/generated/Bolt.java | 497 +
.../storm/generated/ClusterSummary.java | 704 +
.../storm/generated/ComponentCommon.java | 835 +
.../storm/generated/ComponentObject.java | 445 +
.../storm/generated/ComponentSummary.java | 903 +
.../backtype/storm/generated/Credentials.java | 441 +
.../storm/generated/DRPCExecutionException.java | 389 +
.../backtype/storm/generated/DRPCRequest.java | 490 +
.../storm/generated/DistributedRPC.java | 1195 +
.../generated/DistributedRPCInvocations.java | 2545 ++
.../backtype/storm/generated/ErrorInfo.java | 488 +
.../storm/generated/GlobalStreamId.java | 490 +
.../java/backtype/storm/generated/Grouping.java | 844 +
.../generated/InvalidTopologyException.java | 389 +
.../backtype/storm/generated/JavaObject.java | 544 +
.../backtype/storm/generated/JavaObjectArg.java | 614 +
.../backtype/storm/generated/KillOptions.java | 390 +
.../storm/generated/LocalStateData.java | 454 +
.../backtype/storm/generated/MetricInfo.java | 902 +
.../backtype/storm/generated/MetricWindow.java | 441 +
.../storm/generated/MonitorOptions.java | 390 +
.../backtype/storm/generated/NettyMetric.java | 553 +
.../java/backtype/storm/generated/Nimbus.java | 28951 +++++++++++++++++
.../backtype/storm/generated/NimbusStat.java | 490 +
.../backtype/storm/generated/NimbusSummary.java | 1034 +
.../storm/generated/NotAliveException.java | 389 +
.../backtype/storm/generated/NullStruct.java | 283 +
.../storm/generated/RebalanceOptions.java | 595 +
.../storm/generated/ShellComponent.java | 499 +
.../backtype/storm/generated/SpoutSpec.java | 497 +
.../storm/generated/StateSpoutSpec.java | 497 +
.../backtype/storm/generated/StormTopology.java | 786 +
.../backtype/storm/generated/StreamInfo.java | 537 +
.../backtype/storm/generated/SubmitOptions.java | 401 +
.../storm/generated/SupervisorSummary.java | 779 +
.../storm/generated/SupervisorWorkers.java | 715 +
.../backtype/storm/generated/TaskComponent.java | 488 +
.../backtype/storm/generated/TaskSummary.java | 943 +
.../storm/generated/ThriftSerializedObject.java | 499 +
.../generated/TopologyAssignException.java | 389 +
.../backtype/storm/generated/TopologyInfo.java | 810 +
.../storm/generated/TopologyInitialStatus.java | 45 +
.../storm/generated/TopologyMetric.java | 892 +
.../storm/generated/TopologySummary.java | 990 +
.../backtype/storm/generated/WorkerSummary.java | 738 +
.../storm/generated/WorkerUploadMetrics.java | 967 +
.../storm/grouping/CustomStreamGrouping.java | 43 +
.../storm/grouping/PartialKeyGrouping.java | 82 +
.../java/backtype/storm/hooks/BaseTaskHook.java | 61 +
.../java/backtype/storm/hooks/ITaskHook.java | 38 +
.../backtype/storm/hooks/info/BoltAckInfo.java | 32 +
.../storm/hooks/info/BoltExecuteInfo.java | 32 +
.../backtype/storm/hooks/info/BoltFailInfo.java | 32 +
.../backtype/storm/hooks/info/EmitInfo.java | 35 +
.../backtype/storm/hooks/info/SpoutAckInfo.java | 30 +
.../storm/hooks/info/SpoutFailInfo.java | 30 +
.../storm/messaging/ConnectionWithStatus.java | 49 +
.../backtype/storm/messaging/IConnection.java | 54 +
.../java/backtype/storm/messaging/IContext.java | 68 +
.../backtype/storm/messaging/TaskMessage.java | 68 +
.../storm/messaging/TransportFactory.java | 68 +
.../storm/metric/LoggingMetricsConsumer.java | 72 +
.../storm/metric/MetricsConsumerBolt.java | 64 +
.../java/backtype/storm/metric/SystemBolt.java | 155 +
.../storm/metric/api/AssignableMetric.java | 34 +
.../storm/metric/api/CombinedMetric.java | 38 +
.../backtype/storm/metric/api/CountMetric.java | 41 +
.../backtype/storm/metric/api/ICombiner.java | 23 +
.../java/backtype/storm/metric/api/IMetric.java | 22 +
.../storm/metric/api/IMetricsConsumer.java | 60 +
.../backtype/storm/metric/api/IReducer.java | 24 +
.../storm/metric/api/IStatefulObject.java | 22 +
.../backtype/storm/metric/api/MeanReducer.java | 55 +
.../storm/metric/api/MultiCountMetric.java | 45 +
.../storm/metric/api/MultiReducedMetric.java | 50 +
.../storm/metric/api/ReducedMetric.java | 38 +
.../backtype/storm/metric/api/StateMetric.java | 31 +
.../metric/api/rpc/AssignableShellMetric.java | 30 +
.../metric/api/rpc/CombinedShellMetric.java | 31 +
.../storm/metric/api/rpc/CountShellMetric.java | 38 +
.../storm/metric/api/rpc/IShellMetric.java | 31 +
.../metric/api/rpc/ReducedShellMetric.java | 32 +
.../java/backtype/storm/multilang/BoltMsg.java | 80 +
.../backtype/storm/multilang/ISerializer.java | 82 +
.../storm/multilang/JsonSerializer.java | 202 +
.../storm/multilang/NoOutputException.java | 40 +
.../java/backtype/storm/multilang/ShellMsg.java | 185 +
.../java/backtype/storm/multilang/SpoutMsg.java | 51 +
.../storm/nimbus/DefaultTopologyValidator.java | 31 +
.../storm/nimbus/ITopologyValidator.java | 28 +
.../backtype/storm/planner/CompoundSpout.java | 25 +
.../backtype/storm/planner/CompoundTask.java | 25 +
.../java/backtype/storm/planner/TaskBundle.java | 33 +
.../java/backtype/storm/scheduler/Cluster.java | 448 +
.../storm/scheduler/ExecutorDetails.java | 54 +
.../java/backtype/storm/scheduler/INimbus.java | 39 +
.../backtype/storm/scheduler/IScheduler.java | 40 +
.../backtype/storm/scheduler/ISupervisor.java | 45 +
.../storm/scheduler/SchedulerAssignment.java | 58 +
.../scheduler/SchedulerAssignmentImpl.java | 110 +
.../storm/scheduler/SupervisorDetails.java | 89 +
.../backtype/storm/scheduler/Topologies.java | 57 +
.../storm/scheduler/TopologyDetails.java | 89 +
.../backtype/storm/scheduler/WorkerSlot.java | 104 +
.../scheduler/multitenant/DefaultPool.java | 219 +
.../storm/scheduler/multitenant/FreePool.java | 125 +
.../scheduler/multitenant/IsolatedPool.java | 346 +
.../multitenant/MultitenantScheduler.java | 98 +
.../storm/scheduler/multitenant/Node.java | 343 +
.../storm/scheduler/multitenant/NodePool.java | 296 +
.../storm/security/INimbusCredentialPlugin.java | 47 +
.../backtype/storm/security/auth/AuthUtils.java | 284 +
.../auth/DefaultHttpCredentialsPlugin.java | 96 +
.../security/auth/DefaultPrincipalToLocal.java | 43 +
.../storm/security/auth/IAuthorizer.java | 47 +
.../storm/security/auth/IAutoCredentials.java | 55 +
.../security/auth/ICredentialsRenewer.java | 41 +
.../auth/IGroupMappingServiceProvider.java | 42 +
.../security/auth/IHttpCredentialsPlugin.java | 50 +
.../storm/security/auth/IPrincipalToLocal.java | 41 +
.../storm/security/auth/ITransportPlugin.java | 61 +
.../security/auth/KerberosPrincipalToLocal.java | 45 +
.../storm/security/auth/ReqContext.java | 142 +
.../security/auth/SaslTransportPlugin.java | 176 +
.../security/auth/ShellBasedGroupsMapping.java | 94 +
.../security/auth/SimpleTransportPlugin.java | 163 +
.../security/auth/SingleUserPrincipal.java | 56 +
.../storm/security/auth/TBackoffConnect.java | 77 +
.../storm/security/auth/ThriftClient.java | 204 +
.../security/auth/ThriftConnectionType.java | 77 +
.../storm/security/auth/ThriftServer.java | 80 +
.../auth/authorizer/DRPCAuthorizerBase.java | 46 +
.../authorizer/DRPCSimpleACLAuthorizer.java | 157 +
.../auth/authorizer/DenyAuthorizer.java | 57 +
.../authorizer/ImpersonationAuthorizer.java | 154 +
.../auth/authorizer/NoopAuthorizer.java | 57 +
.../auth/authorizer/SimpleACLAuthorizer.java | 152 +
.../authorizer/SimpleWhitelistAuthorizer.java | 70 +
.../auth/digest/ClientCallbackHandler.java | 110 +
.../auth/digest/DigestSaslTransportPlugin.java | 70 +
.../auth/digest/ServerCallbackHandler.java | 131 +
.../storm/security/auth/kerberos/AutoTGT.java | 281 +
.../auth/kerberos/AutoTGTKrb5LoginModule.java | 108 +
.../kerberos/AutoTGTKrb5LoginModuleTest.java | 44 +
.../auth/kerberos/ClientCallbackHandler.java | 104 +
.../kerberos/KerberosSaslTransportPlugin.java | 209 +
.../auth/kerberos/ServerCallbackHandler.java | 94 +
.../auth/kerberos/jaas_kerberos_cluster.conf | 31 +
.../auth/kerberos/jaas_kerberos_launcher.conf | 12 +
.../serialization/BlowfishTupleSerializer.java | 90 +
.../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 | 25 +
.../storm/serialization/ITupleSerializer.java | 26 +
.../serialization/KryoTupleDeserializer.java | 129 +
.../serialization/KryoTupleSerializer.java | 112 +
.../serialization/KryoValuesDeserializer.java | 51 +
.../serialization/KryoValuesSerializer.java | 58 +
.../serialization/SerializableSerializer.java | 62 +
.../serialization/SerializationDelegate.java | 35 +
.../serialization/SerializationFactory.java | 226 +
.../ThriftSerializationDelegate.java | 52 +
.../types/ArrayListSerializer.java | 32 +
.../serialization/types/HashMapSerializer.java | 32 +
.../serialization/types/HashSetSerializer.java | 32 +
.../types/ListDelegateSerializer.java | 32 +
.../storm/spout/IMultiSchemableSpout.java | 23 +
.../backtype/storm/spout/ISchemableSpout.java | 24 +
.../main/java/backtype/storm/spout/ISpout.java | 105 +
.../storm/spout/ISpoutOutputCollector.java | 30 +
.../storm/spout/ISpoutWaitStrategy.java | 34 +
.../java/backtype/storm/spout/MultiScheme.java | 28 +
.../storm/spout/NothingEmptyEmitStrategy.java | 31 +
.../backtype/storm/spout/RawMultiScheme.java | 38 +
.../java/backtype/storm/spout/RawScheme.java | 32 +
.../main/java/backtype/storm/spout/Scheme.java | 28 +
.../storm/spout/SchemeAsMultiScheme.java | 41 +
.../java/backtype/storm/spout/ShellSpout.java | 266 +
.../storm/spout/SleepSpoutWaitStrategy.java | 41 +
.../storm/spout/SpoutOutputCollector.java | 134 +
.../java/backtype/storm/state/IStateSpout.java | 29 +
.../storm/state/IStateSpoutOutputCollector.java | 22 +
.../backtype/storm/state/ISubscribedState.java | 25 +
.../state/ISynchronizeOutputCollector.java | 24 +
.../storm/state/StateSpoutOutputCollector.java | 28 +
.../storm/state/SynchronizeOutputCollector.java | 30 +
.../storm/task/GeneralTopologyContext.java | 209 +
.../main/java/backtype/storm/task/IBolt.java | 84 +
.../backtype/storm/task/IErrorReporter.java | 22 +
.../backtype/storm/task/IMetricsContext.java | 31 +
.../backtype/storm/task/IOutputCollector.java | 32 +
.../backtype/storm/task/OutputCollector.java | 225 +
.../java/backtype/storm/task/ShellBolt.java | 386 +
.../backtype/storm/task/TopologyContext.java | 360 +
.../storm/task/WorkerTopologyContext.java | 109 +
.../backtype/storm/testing/AckFailDelegate.java | 25 +
.../storm/testing/AckFailMapTracker.java | 52 +
.../java/backtype/storm/testing/AckTracker.java | 52 +
.../backtype/storm/testing/BatchNumberList.java | 72 +
.../storm/testing/BatchProcessWord.java | 39 +
.../backtype/storm/testing/BatchRepeatA.java | 48 +
.../backtype/storm/testing/BoltTracker.java | 42 +
.../storm/testing/CompleteTopologyParam.java | 87 +
.../storm/testing/CountingBatchBolt.java | 55 +
.../storm/testing/CountingCommitBolt.java | 57 +
.../backtype/storm/testing/FeederSpout.java | 100 +
.../java/backtype/storm/testing/FixedTuple.java | 42 +
.../backtype/storm/testing/FixedTupleSpout.java | 179 +
.../testing/ForwardingMetricsConsumer.java | 95 +
.../backtype/storm/testing/IdentityBolt.java | 42 +
.../storm/testing/KeyedCountingBatchBolt.java | 61 +
.../testing/KeyedCountingCommitterBolt.java | 24 +
.../storm/testing/KeyedSummingBatchBolt.java | 61 +
.../storm/testing/MemoryTransactionalSpout.java | 181 +
.../testing/MemoryTransactionalSpoutMeta.java | 38 +
.../backtype/storm/testing/MkClusterParam.java | 57 +
.../backtype/storm/testing/MkTupleParam.java | 51 +
.../backtype/storm/testing/MockedSources.java | 60 +
.../java/backtype/storm/testing/NGrouping.java | 50 +
.../storm/testing/NonRichBoltTracker.java | 51 +
.../testing/OpaqueMemoryTransactionalSpout.java | 186 +
.../storm/testing/PrepareBatchBolt.java | 52 +
.../storm/testing/PythonShellMetricsBolt.java | 49 +
.../storm/testing/PythonShellMetricsSpout.java | 52 +
.../testing/SingleUserSimpleTransport.java | 37 +
.../backtype/storm/testing/SpoutTracker.java | 105 +
.../storm/testing/TestAggregatesCounter.java | 63 +
.../backtype/storm/testing/TestConfBolt.java | 62 +
.../storm/testing/TestEventLogSpout.java | 139 +
.../storm/testing/TestEventOrderCheckBolt.java | 76 +
.../backtype/storm/testing/TestGlobalCount.java | 60 +
.../java/backtype/storm/testing/TestJob.java | 41 +
.../storm/testing/TestKryoDecorator.java | 31 +
.../backtype/storm/testing/TestPlannerBolt.java | 45 +
.../storm/testing/TestPlannerSpout.java | 85 +
.../backtype/storm/testing/TestSerObject.java | 56 +
.../backtype/storm/testing/TestWordCounter.java | 61 +
.../backtype/storm/testing/TestWordSpout.java | 86 +
.../backtype/storm/testing/TrackedTopology.java | 34 +
.../storm/testing/TupleCaptureBolt.java | 83 +
.../topology/BaseConfigurationDeclarer.java | 54 +
.../storm/topology/BasicBoltExecutor.java | 67 +
.../storm/topology/BasicOutputCollector.java | 62 +
.../backtype/storm/topology/BoltDeclarer.java | 26 +
.../ComponentConfigurationDeclarer.java | 29 +
.../storm/topology/FailedException.java | 36 +
.../backtype/storm/topology/IBasicBolt.java | 33 +
.../storm/topology/IBasicOutputCollector.java | 26 +
.../backtype/storm/topology/IComponent.java | 44 +
.../java/backtype/storm/topology/IConfig.java | 28 +
.../java/backtype/storm/topology/IRichBolt.java | 29 +
.../backtype/storm/topology/IRichSpout.java | 29 +
.../storm/topology/IRichStateSpout.java | 25 +
.../backtype/storm/topology/InputDeclarer.java | 187 +
.../storm/topology/OutputFieldsDeclarer.java | 32 +
.../storm/topology/OutputFieldsGetter.java | 53 +
.../storm/topology/ReportedFailedException.java | 36 +
.../backtype/storm/topology/SpoutDeclarer.java | 22 +
.../storm/topology/TopologyBuilder.java | 384 +
.../storm/topology/base/BaseBasicBolt.java | 33 +
.../storm/topology/base/BaseBatchBolt.java | 25 +
.../storm/topology/base/BaseComponent.java | 28 +
...BaseOpaquePartitionedTransactionalSpout.java | 25 +
.../base/BasePartitionedTransactionalSpout.java | 25 +
.../storm/topology/base/BaseRichBolt.java | 26 +
.../storm/topology/base/BaseRichSpout.java | 50 +
.../topology/base/BaseTransactionalBolt.java | 24 +
.../topology/base/BaseTransactionalSpout.java | 25 +
.../storm/transactional/ICommitter.java | 26 +
.../ICommitterTransactionalSpout.java | 31 +
.../transactional/ITransactionalSpout.java | 94 +
.../storm/transactional/TransactionAttempt.java | 61 +
.../TransactionalSpoutBatchExecutor.java | 96 +
.../TransactionalSpoutCoordinator.java | 217 +
.../TransactionalTopologyBuilder.java | 553 +
.../IOpaquePartitionedTransactionalSpout.java | 56 +
.../IPartitionedTransactionalSpout.java | 69 +
...uePartitionedTransactionalSpoutExecutor.java | 159 +
.../PartitionedTransactionalSpoutExecutor.java | 142 +
.../state/RotatingTransactionalState.java | 151 +
.../state/TestTransactionalState.java | 47 +
.../transactional/state/TransactionalState.java | 173 +
.../java/backtype/storm/tuple/BatchTuple.java | 77 +
.../main/java/backtype/storm/tuple/Fields.java | 100 +
.../main/java/backtype/storm/tuple/ITuple.java | 136 +
.../java/backtype/storm/tuple/MessageId.java | 103 +
.../main/java/backtype/storm/tuple/Tuple.java | 60 +
.../java/backtype/storm/tuple/TupleExt.java | 29 +
.../java/backtype/storm/tuple/TupleImpl.java | 351 +
.../java/backtype/storm/tuple/TupleImplExt.java | 46 +
.../main/java/backtype/storm/tuple/Values.java | 37 +
.../storm/ui/InvalidRequestException.java | 37 +
.../storm/utils/BufferFileInputStream.java | 54 +
.../backtype/storm/utils/CRC32OutputStream.java | 44 +
.../backtype/storm/utils/ClojureTimerTask.java | 35 +
.../java/backtype/storm/utils/Container.java | 24 +
.../java/backtype/storm/utils/DRPCClient.java | 65 +
.../backtype/storm/utils/DisruptorQueue.java | 80 +
.../storm/utils/DisruptorQueueImpl.java | 306 +
.../storm/utils/DisruptorWrapBlockingQueue.java | 200 +
.../storm/utils/ExtendedThreadPoolExecutor.java | 67 +
.../storm/utils/IndifferentAccessMap.java | 177 +
.../backtype/storm/utils/InprocMessaging.java | 59 +
.../storm/utils/KeyedRoundRobinQueue.java | 68 +
.../java/backtype/storm/utils/ListDelegate.java | 156 +
.../java/backtype/storm/utils/LocalState.java | 99 +
.../main/java/backtype/storm/utils/Monitor.java | 268 +
.../java/backtype/storm/utils/MutableInt.java | 43 +
.../java/backtype/storm/utils/MutableLong.java | 43 +
.../backtype/storm/utils/MutableObject.java | 38 +
.../java/backtype/storm/utils/NimbusClient.java | 107 +
.../storm/utils/RegisteredGlobalState.java | 64 +
.../java/backtype/storm/utils/RotatingMap.java | 125 +
.../backtype/storm/utils/ServiceRegistry.java | 47 +
.../java/backtype/storm/utils/ShellProcess.java | 189 +
.../java/backtype/storm/utils/ShellUtils.java | 498 +
.../StormBoundedExponentialBackoffRetry.java | 74 +
.../java/backtype/storm/utils/TestUtils.java | 34 +
.../storm/utils/ThreadResourceManager.java | 45 +
.../storm/utils/ThriftTopologyUtils.java | 69 +
.../main/java/backtype/storm/utils/Time.java | 109 +
.../java/backtype/storm/utils/TimeCacheMap.java | 169 +
.../backtype/storm/utils/TransferDrainer.java | 113 +
.../java/backtype/storm/utils/TupleHelpers.java | 31 +
.../java/backtype/storm/utils/TupleUtils.java | 35 +
.../main/java/backtype/storm/utils/Utils.java | 906 +
.../java/backtype/storm/utils/VersionInfo.java | 131 +
.../backtype/storm/utils/VersionedStore.java | 187 +
.../storm/utils/WindowedTimeThrottler.java | 51 +
.../backtype/storm/utils/WorkerClassLoader.java | 188 +
.../backtype/storm/utils/WritableUtils.java | 375 +
.../backtype/storm/utils/ZookeeperAuthInfo.java | 53 +
.../storm/utils/ZookeeperServerCnxnFactory.java | 84 +
.../utils/disruptor/AbstractSequencerExt.java | 38 +
.../utils/disruptor/MultiProducerSequencer.java | 267 +
.../storm/utils/disruptor/RingBuffer.java | 996 +
.../disruptor/SingleProducerSequencer.java | 197 +
.../java/com/alibaba/jstorm/batch/BatchId.java | 83 +
.../jstorm/batch/BatchTopologyBuilder.java | 88 +
.../com/alibaba/jstorm/batch/IBatchSpout.java | 55 +
.../com/alibaba/jstorm/batch/ICommitter.java | 52 +
.../com/alibaba/jstorm/batch/IPostCommit.java | 29 +
.../alibaba/jstorm/batch/IPrepareCommit.java | 38 +
.../jstorm/batch/impl/BatchSpoutMsgId.java | 65 +
.../jstorm/batch/impl/BatchSpoutTrigger.java | 333 +
.../jstorm/batch/impl/CoordinatedBolt.java | 300 +
.../alibaba/jstorm/batch/util/BatchCommon.java | 89 +
.../com/alibaba/jstorm/batch/util/BatchDef.java | 41 +
.../alibaba/jstorm/batch/util/BatchStatus.java | 43 +
.../com/alibaba/jstorm/cache/JStormCache.java | 49 +
.../com/alibaba/jstorm/cache/RocksDBCache.java | 311 +
.../alibaba/jstorm/cache/RocksTTLDBCache.java | 469 +
.../alibaba/jstorm/cache/TimeoutMemCache.java | 178 +
.../jstorm/callback/AsyncLoopDefaultKill.java | 42 +
.../jstorm/callback/AsyncLoopRunnable.java | 127 +
.../jstorm/callback/AsyncLoopThread.java | 140 +
.../alibaba/jstorm/callback/BaseCallback.java | 28 +
.../com/alibaba/jstorm/callback/Callback.java | 30 +
.../jstorm/callback/ClusterStateCallback.java | 22 +
.../jstorm/callback/DefaultWatcherCallBack.java | 45 +
.../jstorm/callback/RunnableCallback.java | 64 +
.../jstorm/callback/WatcherCallBack.java | 25 +
.../callback/impl/ActiveTransitionCallback.java | 36 +
.../impl/DelayStatusTransitionCallback.java | 111 +
.../impl/DoRebalanceTransitionCallback.java | 307 +
.../impl/DoneRebalanceTransitionCallback.java | 22 +
.../impl/InactiveTransitionCallback.java | 38 +
.../callback/impl/KillTransitionCallback.java | 38 +
.../impl/ReassignTransitionCallback.java | 66 +
.../impl/RebalanceTransitionCallback.java | 42 +
.../callback/impl/RemoveTransitionCallback.java | 71 +
.../impl/UpdateConfTransitionCallback.java | 79 +
.../alibaba/jstorm/client/ConfigExtension.java | 867 +
.../alibaba/jstorm/client/WorkerAssignment.java | 283 +
.../jstorm/client/spout/IAckValueSpout.java | 32 +
.../jstorm/client/spout/IFailValueSpout.java | 32 +
.../com/alibaba/jstorm/cluster/Cluster.java | 398 +
.../alibaba/jstorm/cluster/ClusterState.java | 56 +
.../java/com/alibaba/jstorm/cluster/Common.java | 845 +
.../alibaba/jstorm/cluster/DaemonCommon.java | 22 +
.../jstorm/cluster/DistributedClusterState.java | 242 +
.../com/alibaba/jstorm/cluster/StormBase.java | 144 +
.../jstorm/cluster/StormClusterState.java | 162 +
.../com/alibaba/jstorm/cluster/StormConfig.java | 549 +
.../alibaba/jstorm/cluster/StormMonitor.java | 50 +
.../com/alibaba/jstorm/cluster/StormStatus.java | 123 +
.../jstorm/cluster/StormZkClusterState.java | 759 +
.../alibaba/jstorm/common/metric/Counter.java | 55 +
.../com/alibaba/jstorm/common/metric/Gauge.java | 61 +
.../alibaba/jstorm/common/metric/Histogram.java | 104 +
.../jstorm/common/metric/Histogram.java.bak | 71 +
.../jstorm/common/metric/LongCounter.java | 39 +
.../com/alibaba/jstorm/common/metric/Meter.java | 50 +
.../jstorm/common/metric/MetricFilter.java | 46 +
.../jstorm/common/metric/MetricRegistry.java | 316 +
.../alibaba/jstorm/common/metric/MetricSet.java | 28 +
.../jstorm/common/metric/QueueGauge.java | 61 +
.../com/alibaba/jstorm/common/metric/Timer.java | 108 +
.../jstorm/common/metric/TimerRatio.java | 73 +
.../com/alibaba/jstorm/common/metric/Top.java | 157 +
.../jstorm/common/metric/operator/Sampling.java | 38 +
.../common/metric/operator/StartTime.java | 22 +
.../operator/convert/AtomicLongToLong.java | 35 +
.../metric/operator/convert/Convertor.java | 25 +
.../operator/convert/DefaultConvertor.java | 29 +
.../metric/operator/convert/SetToList.java | 39 +
.../metric/operator/merger/AvgMerger.java | 52 +
.../metric/operator/merger/AvgMerger.java.bak | 53 +
.../metric/operator/merger/LongSumMerger.java | 43 +
.../common/metric/operator/merger/Merger.java | 25 +
.../metric/operator/merger/SumMerger.java | 39 +
.../metric/operator/merger/TpsMerger.java | 65 +
.../metric/operator/updater/AddUpdater.java | 38 +
.../metric/operator/updater/AvgUpdater.java | 62 +
.../metric/operator/updater/AvgUpdater.java.bak | 73 +
.../operator/updater/DoubleAddUpdater.java | 45 +
.../metric/operator/updater/LongAddUpdater.java | 45 +
.../common/metric/operator/updater/Updater.java | 25 +
.../jstorm/common/metric/window/AllWindow.java | 78 +
.../jstorm/common/metric/window/Metric.java | 231 +
.../common/metric/window/RollingWindow.java | 194 +
.../common/metric/window/StatBuckets.java | 153 +
.../jstorm/common/stats/StaticsType.java | 22 +
.../alibaba/jstorm/container/CgroupCenter.java | 224 +
.../jstorm/container/CgroupOperation.java | 46 +
.../alibaba/jstorm/container/CgroupUtils.java | 178 +
.../com/alibaba/jstorm/container/Constants.java | 30 +
.../com/alibaba/jstorm/container/Hierarchy.java | 109 +
.../com/alibaba/jstorm/container/SubSystem.java | 70 +
.../alibaba/jstorm/container/SubSystemType.java | 48 +
.../jstorm/container/cgroup/CgroupCommon.java | 249 +
.../container/cgroup/CgroupCommonOperation.java | 48 +
.../container/cgroup/CgroupCoreFactory.java | 78 +
.../alibaba/jstorm/container/cgroup/Device.java | 68 +
.../jstorm/container/cgroup/core/BlkioCore.java | 306 +
.../container/cgroup/core/CgroupCore.java | 26 +
.../jstorm/container/cgroup/core/CpuCore.java | 148 +
.../container/cgroup/core/CpuacctCore.java | 79 +
.../container/cgroup/core/CpusetCore.java | 274 +
.../container/cgroup/core/DevicesCore.java | 188 +
.../container/cgroup/core/FreezerCore.java | 67 +
.../container/cgroup/core/MemoryCore.java | 229 +
.../container/cgroup/core/NetClsCore.java | 75 +
.../container/cgroup/core/NetPrioCore.java | 72 +
.../jstorm/daemon/nimbus/DefaultInimbus.java | 72 +
.../jstorm/daemon/nimbus/NimbusCache.java | 146 +
.../jstorm/daemon/nimbus/NimbusData.java | 327 +
.../jstorm/daemon/nimbus/NimbusServer.java | 417 +
.../jstorm/daemon/nimbus/NimbusUtils.java | 723 +
.../jstorm/daemon/nimbus/ServiceHandler.java | 1523 +
.../jstorm/daemon/nimbus/StatusTransition.java | 294 +
.../jstorm/daemon/nimbus/StatusType.java | 63 +
.../jstorm/daemon/nimbus/TopologyAssign.java | 996 +
.../daemon/nimbus/TopologyAssignEvent.java | 117 +
.../daemon/nimbus/TopologyMetricsRunnable.java | 727 +
.../jstorm/daemon/nimbus/TopologyNettyMgr.java | 105 +
.../jstorm/daemon/supervisor/CgroupManager.java | 160 +
.../jstorm/daemon/supervisor/Heartbeat.java | 155 +
.../jstorm/daemon/supervisor/Httpserver.java | 482 +
.../jstorm/daemon/supervisor/SandBoxMaker.java | 221 +
.../jstorm/daemon/supervisor/ShutdownWork.java | 193 +
.../daemon/supervisor/StateHeartbeat.java | 53 +
.../jstorm/daemon/supervisor/Supervisor.java | 247 +
.../daemon/supervisor/SupervisorDaemon.java | 30 +
.../daemon/supervisor/SupervisorInfo.java | 186 +
.../daemon/supervisor/SupervisorManger.java | 197 +
.../daemon/supervisor/SyncProcessEvent.java | 1057 +
.../daemon/supervisor/SyncSupervisorEvent.java | 618 +
.../daemon/worker/BatchDrainerRunable.java | 60 +
.../jstorm/daemon/worker/ContextMaker.java | 128 +
.../jstorm/daemon/worker/DrainerRunable.java | 139 +
.../jstorm/daemon/worker/LocalAssignment.java | 162 +
.../jstorm/daemon/worker/ProcessSimulator.java | 100 +
.../jstorm/daemon/worker/RefreshActive.java | 139 +
.../daemon/worker/RefreshConnections.java | 368 +
.../daemon/worker/ShutdownableDameon.java | 27 +
.../com/alibaba/jstorm/daemon/worker/State.java | 28 +
.../daemon/worker/VirtualPortDispatch.java | 99 +
.../alibaba/jstorm/daemon/worker/Worker.java | 492 +
.../jstorm/daemon/worker/WorkerData.java | 615 +
.../jstorm/daemon/worker/WorkerHeartbeat.java | 89 +
.../jstorm/daemon/worker/WorkerShutdown.java | 186 +
.../daemon/worker/hearbeat/SyncContainerHb.java | 386 +
.../worker/hearbeat/WorkerHeartbeatRunable.java | 127 +
.../daemon/worker/timer/RotatingMapTrigger.java | 86 +
.../worker/timer/TaskBatchFlushTrigger.java | 50 +
.../worker/timer/TaskHeartbeatTrigger.java | 84 +
.../daemon/worker/timer/TickTupleTrigger.java | 62 +
.../daemon/worker/timer/TimerConstants.java | 26 +
.../daemon/worker/timer/TimerTrigger.java | 169 +
.../com/alibaba/jstorm/drpc/ClearThread.java | 79 +
.../main/java/com/alibaba/jstorm/drpc/Drpc.java | 319 +
.../com/alibaba/jstorm/event/EventManager.java | 28 +
.../alibaba/jstorm/event/EventManagerImp.java | 84 +
.../jstorm/event/EventManagerPusher.java | 50 +
.../jstorm/event/EventManagerZkPusher.java | 42 +
.../jstorm/message/netty/ControlMessage.java | 86 +
.../jstorm/message/netty/MessageBatch.java | 194 +
.../jstorm/message/netty/MessageDecoder.java | 236 +
.../jstorm/message/netty/MessageEncoder.java | 40 +
.../jstorm/message/netty/NettyClient.java | 614 +
.../jstorm/message/netty/NettyClientAsync.java | 350 +
.../jstorm/message/netty/NettyClientSync.java | 332 +
.../jstorm/message/netty/NettyConnection.java | 91 +
.../jstorm/message/netty/NettyContext.java | 150 +
.../message/netty/NettyRenameThreadFactory.java | 55 +
.../jstorm/message/netty/NettyServer.java | 234 +
.../jstorm/message/netty/ReconnectRunnable.java | 72 +
.../message/netty/StormClientHandler.java | 107 +
.../netty/StormClientPipelineFactory.java | 51 +
.../message/netty/StormServerHandler.java | 140 +
.../netty/StormServerPipelineFactory.java | 48 +
.../alibaba/jstorm/metric/AlimonitorClient.java | 267 +
.../jstorm/metric/JStormHealthCheck.java | 79 +
.../alibaba/jstorm/metric/JStormMetrics.java | 281 +
.../jstorm/metric/JStormMetricsReporter.java | 406 +
.../com/alibaba/jstorm/metric/MetricDef.java | 163 +
.../com/alibaba/jstorm/metric/MetricJstack.java | 140 +
.../alibaba/jstorm/metric/MetricSendClient.java | 18 +
.../com/alibaba/jstorm/metric/MetricThrift.java | 129 +
.../jstorm/metric/SimpleJStormMetric.java | 96 +
.../jstorm/queue/disruptor/JstormEvent.java | 41 +
.../queue/disruptor/JstormEventHandler.java | 47 +
.../jstorm/queue/disruptor/JstormProducer.java | 63 +
.../com/alibaba/jstorm/schedule/Assignment.java | 232 +
.../alibaba/jstorm/schedule/AssignmentBak.java | 55 +
.../alibaba/jstorm/schedule/CleanRunnable.java | 83 +
.../jstorm/schedule/DelayEventRunnable.java | 44 +
.../jstorm/schedule/FollowerRunnable.java | 306 +
.../jstorm/schedule/IToplogyScheduler.java | 31 +
.../jstorm/schedule/MonitorRunnable.java | 125 +
.../jstorm/schedule/TopologyAssignContext.java | 179 +
.../DefaultTopologyAssignContext.java | 221 +
.../DefaultTopologyScheduler.java | 190 +
.../default_assign/ResourceWorkerSlot.java | 162 +
.../Selector/AbstractSelector.java | 71 +
.../Selector/ComponentNumSelector.java | 56 +
.../Selector/InputComponentNumSelector.java | 55 +
.../default_assign/Selector/Selector.java | 27 +
.../Selector/TotalTaskNumSelector.java | 52 +
.../Selector/WorkerComparator.java | 33 +
.../default_assign/TaskAssignContext.java | 133 +
.../schedule/default_assign/TaskScheduler.java | 334 +
.../default_assign/WorkerScheduler.java | 387 +
.../main/java/com/alibaba/jstorm/task/Task.java | 370 +
.../com/alibaba/jstorm/task/TaskBaseMetric.java | 132 +
.../alibaba/jstorm/task/TaskBatchReceiver.java | 99 +
.../alibaba/jstorm/task/TaskBatchTransfer.java | 141 +
.../java/com/alibaba/jstorm/task/TaskInfo.java | 78 +
.../com/alibaba/jstorm/task/TaskReceiver.java | 228 +
.../alibaba/jstorm/task/TaskShutdownDameon.java | 188 +
.../com/alibaba/jstorm/task/TaskStatus.java | 58 +
.../com/alibaba/jstorm/task/TaskTransfer.java | 216 +
.../com/alibaba/jstorm/task/TkHbCacheTime.java | 65 +
.../com/alibaba/jstorm/task/UptimeComputer.java | 38 +
.../alibaba/jstorm/task/acker/AckObject.java | 36 +
.../com/alibaba/jstorm/task/acker/Acker.java | 164 +
.../jstorm/task/comm/TaskSendTargets.java | 151 +
.../com/alibaba/jstorm/task/comm/TupleInfo.java | 73 +
.../jstorm/task/comm/UnanchoredSend.java | 54 +
.../jstorm/task/error/ITaskReportErr.java | 28 +
.../alibaba/jstorm/task/error/TaskError.java | 55 +
.../jstorm/task/error/TaskErrorRunable.java | 48 +
.../jstorm/task/error/TaskReportError.java | 59 +
.../task/error/TaskReportErrorAndDie.java | 43 +
.../jstorm/task/execute/BaseExecutors.java | 232 +
.../jstorm/task/execute/BoltCollector.java | 259 +
.../jstorm/task/execute/BoltExecutors.java | 290 +
.../jstorm/task/execute/spout/AckSpoutMsg.java | 79 +
.../jstorm/task/execute/spout/FailSpoutMsg.java | 71 +
.../jstorm/task/execute/spout/IAckMsg.java | 22 +
.../spout/MultipleThreadSpoutExecutors.java | 131 +
.../spout/SingleThreadSpoutExecutors.java | 96 +
.../task/execute/spout/SpoutCollector.java | 218 +
.../task/execute/spout/SpoutExecutors.java | 357 +
.../execute/spout/SpoutTimeoutCallBack.java | 74 +
.../alibaba/jstorm/task/group/GrouperType.java | 28 +
.../jstorm/task/group/MkCustomGrouper.java | 49 +
.../jstorm/task/group/MkFieldsGrouper.java | 60 +
.../alibaba/jstorm/task/group/MkGrouper.java | 203 +
.../alibaba/jstorm/task/group/MkLocalFirst.java | 144 +
.../jstorm/task/group/MkLocalShuffer.java | 73 +
.../alibaba/jstorm/task/group/MkShuffer.java | 55 +
.../com/alibaba/jstorm/task/group/Shuffer.java | 50 +
.../jstorm/task/heartbeat/TaskHeartbeat.java | 98 +
.../task/heartbeat/TaskHeartbeatRunable.java | 191 +
.../jstorm/task/heartbeat/TaskStats.java | 38 +
.../alibaba/jstorm/utils/DisruptorQueue.java | 168 +
.../alibaba/jstorm/utils/DisruptorRunable.java | 113 +
.../com/alibaba/jstorm/utils/EPlatform.java | 50 +
.../com/alibaba/jstorm/utils/EventSampler.java | 116 +
.../alibaba/jstorm/utils/ExpiredCallback.java | 22 +
.../utils/FailedAssignTopologyException.java | 39 +
.../com/alibaba/jstorm/utils/FileAttribute.java | 135 +
.../alibaba/jstorm/utils/HttpserverUtils.java | 46 +
.../com/alibaba/jstorm/utils/IntervalCheck.java | 83 +
.../alibaba/jstorm/utils/JStormServerUtils.java | 153 +
.../com/alibaba/jstorm/utils/JStormUtils.java | 1279 +
.../java/com/alibaba/jstorm/utils/LoadConf.java | 141 +
.../com/alibaba/jstorm/utils/NetWorkUtils.java | 180 +
.../java/com/alibaba/jstorm/utils/OSInfo.java | 157 +
.../alibaba/jstorm/utils/OlderFileFilter.java | 46 +
.../java/com/alibaba/jstorm/utils/Pair.java | 53 +
.../com/alibaba/jstorm/utils/PathUtils.java | 148 +
.../com/alibaba/jstorm/utils/RandomRange.java | 74 +
.../com/alibaba/jstorm/utils/RotatingMap.java | 149 +
.../com/alibaba/jstorm/utils/RunCounter.java | 100 +
.../com/alibaba/jstorm/utils/SmartThread.java | 35 +
.../alibaba/jstorm/utils/SystemOperation.java | 76 +
.../java/com/alibaba/jstorm/utils/Thrift.java | 501 +
.../com/alibaba/jstorm/utils/TimeCacheMap.java | 173 +
.../alibaba/jstorm/utils/TimeCacheQueue.java | 186 +
.../com/alibaba/jstorm/utils/TimeFormat.java | 219 +
.../com/alibaba/jstorm/utils/TimeOutMap.java | 34 +
.../com/alibaba/jstorm/utils/TimeUtils.java | 51 +
.../java/com/alibaba/jstorm/zk/Factory.java | 37 +
.../com/alibaba/jstorm/zk/ZkCreateModes.java | 38 +
.../com/alibaba/jstorm/zk/ZkEventTypes.java | 44 +
.../com/alibaba/jstorm/zk/ZkKeeperStates.java | 41 +
.../main/java/com/alibaba/jstorm/zk/ZkTool.java | 218 +
.../java/com/alibaba/jstorm/zk/Zookeeper.java | 237 +
.../src/main/java/storm/trident/JoinType.java | 30 +
.../src/main/java/storm/trident/Stream.java | 377 +
.../main/java/storm/trident/TridentState.java | 40 +
.../java/storm/trident/TridentTopology.java | 815 +
.../trident/drpc/ReturnResultsReducer.java | 121 +
.../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 +
.../java/storm/trident/fluent/UniqueIdGen.java | 34 +
.../java/storm/trident/graph/GraphGrouper.java | 123 +
.../main/java/storm/trident/graph/Group.java | 87 +
.../storm/trident/operation/Aggregator.java | 26 +
.../java/storm/trident/operation/Assembly.java | 25 +
.../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 | 32 +
.../trident/operation/CombinerAggregator.java | 29 +
.../storm/trident/operation/EachOperation.java | 22 +
.../java/storm/trident/operation/Filter.java | 25 +
.../java/storm/trident/operation/Function.java | 24 +
.../trident/operation/GroupedMultiReducer.java | 31 +
.../storm/trident/operation/MultiReducer.java | 31 +
.../java/storm/trident/operation/Operation.java | 26 +
.../trident/operation/ReducerAggregator.java | 26 +
.../trident/operation/TridentCollector.java | 26 +
.../operation/TridentMultiReducerContext.java | 36 +
.../operation/TridentOperationContext.java | 65 +
.../storm/trident/operation/builtin/Count.java | 41 +
.../storm/trident/operation/builtin/Debug.java | 39 +
.../storm/trident/operation/builtin/Equals.java | 38 +
.../trident/operation/builtin/FilterNull.java | 31 +
.../storm/trident/operation/builtin/FirstN.java | 125 +
.../storm/trident/operation/builtin/MapGet.java | 38 +
.../storm/trident/operation/builtin/Negate.java | 48 +
.../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 +
.../trident/operation/impl/FilterExecutor.java | 53 +
.../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 +
.../operation/impl/JoinerMultiReducer.java | 159 +
.../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 | 45 +
.../trident/partition/IdentityGrouping.java | 61 +
.../trident/partition/IndexHashGrouping.java | 53 +
.../storm/trident/planner/BridgeReceiver.java | 38 +
.../main/java/storm/trident/planner/Node.java | 64 +
.../storm/trident/planner/NodeStateInfo.java | 31 +
.../storm/trident/planner/PartitionNode.java | 52 +
.../storm/trident/planner/ProcessorContext.java | 29 +
.../storm/trident/planner/ProcessorNode.java | 33 +
.../java/storm/trident/planner/SpoutNode.java | 39 +
.../storm/trident/planner/SubtopologyBolt.java | 218 +
.../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 +
.../processor/MultiReducerProcessor.java | 93 +
.../processor/PartitionPersistProcessor.java | 107 +
.../planner/processor/ProjectedProcessor.java | 73 +
.../planner/processor/StateQueryProcessor.java | 106 +
.../planner/processor/TridentContext.java | 76 +
.../storm/trident/spout/BatchSpoutExecutor.java | 92 +
.../main/java/storm/trident/spout/IBatchID.java | 24 +
.../java/storm/trident/spout/IBatchSpout.java | 33 +
.../trident/spout/ICommitterTridentSpout.java | 31 +
.../spout/IOpaquePartitionedTridentSpout.java | 62 +
.../trident/spout/IPartitionedTridentSpout.java | 77 +
.../storm/trident/spout/ISpoutPartition.java | 25 +
.../java/storm/trident/spout/ITridentSpout.java | 94 +
.../OpaquePartitionedTridentSpoutExecutor.java | 201 +
.../spout/PartitionedTridentSpoutExecutor.java | 171 +
.../trident/spout/RichSpoutBatchExecutor.java | 199 +
.../storm/trident/spout/RichSpoutBatchId.java | 49 +
.../spout/RichSpoutBatchIdSerializer.java | 38 +
.../trident/spout/RichSpoutBatchTriggerer.java | 178 +
.../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 | 36 +
.../storm/trident/state/ITupleCollection.java | 26 +
.../state/JSONNonTransactionalSerializer.java | 44 +
.../trident/state/JSONOpaqueSerializer.java | 52 +
.../state/JSONTransactionalSerializer.java | 50 +
.../java/storm/trident/state/OpaqueValue.java | 75 +
.../java/storm/trident/state/QueryFunction.java | 28 +
.../java/storm/trident/state/ReadOnlyState.java | 31 +
.../trident/state/ReducerValueUpdater.java | 41 +
.../java/storm/trident/state/Serializer.java | 26 +
.../main/java/storm/trident/state/State.java | 39 +
.../java/storm/trident/state/StateFactory.java | 26 +
.../java/storm/trident/state/StateSpec.java | 30 +
.../java/storm/trident/state/StateType.java | 25 +
.../java/storm/trident/state/StateUpdater.java | 33 +
.../storm/trident/state/TransactionalValue.java | 44 +
.../java/storm/trident/state/ValueUpdater.java | 23 +
.../trident/state/map/CachedBatchReadsMap.java | 80 +
.../java/storm/trident/state/map/CachedMap.java | 79 +
.../storm/trident/state/map/IBackingMap.java | 26 +
.../state/map/MapCombinerAggStateUpdater.java | 83 +
.../state/map/MapReducerAggStateUpdater.java | 92 +
.../java/storm/trident/state/map/MapState.java | 26 +
.../state/map/MicroBatchIBackingMap.java | 85 +
.../trident/state/map/NonTransactionalMap.java | 67 +
.../java/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 +
.../java/storm/trident/testing/IFeeder.java | 23 +
.../trident/testing/LRUMemoryMapState.java | 154 +
.../storm/trident/testing/MemoryBackingMap.java | 47 +
.../storm/trident/testing/MemoryMapState.java | 176 +
.../main/java/storm/trident/testing/Split.java | 36 +
.../storm/trident/testing/StringLength.java | 32 +
.../java/storm/trident/testing/TrueFilter.java | 30 +
.../java/storm/trident/testing/TuplifyArgs.java | 37 +
.../java/storm/trident/topology/BatchInfo.java | 33 +
.../trident/topology/ITridentBatchBolt.java | 32 +
.../topology/MasterBatchCoordinator.java | 289 +
.../trident/topology/TransactionAttempt.java | 66 +
.../trident/topology/TridentBoltExecutor.java | 426 +
.../topology/TridentTopologyBuilder.java | 782 +
.../state/RotatingTransactionalState.java | 147 +
.../topology/state/TestTransactionalState.java | 47 +
.../topology/state/TransactionalState.java | 171 +
.../java/storm/trident/tuple/ComboList.java | 92 +
.../main/java/storm/trident/tuple/ConsList.java | 44 +
.../java/storm/trident/tuple/TridentTuple.java | 34 +
.../storm/trident/tuple/TridentTupleView.java | 359 +
.../java/storm/trident/tuple/ValuePointer.java | 60 +
.../storm/trident/util/ErrorEdgeFactory.java | 28 +
.../java/storm/trident/util/IndexedEdge.java | 50 +
.../main/java/storm/trident/util/LRUMap.java | 35 +
.../java/storm/trident/util/TridentUtils.java | 142 +
jstorm-core/src/main/py/__init__.py | 0
.../src/main/py/storm/DistributedRPC-remote | 94 +
jstorm-core/src/main/py/storm/DistributedRPC.py | 265 +
.../py/storm/DistributedRPCInvocations-remote | 108 +
.../main/py/storm/DistributedRPCInvocations.py | 565 +
jstorm-core/src/main/py/storm/Nimbus-remote | 304 +
jstorm-core/src/main/py/storm/Nimbus.py | 5971 ++++
jstorm-core/src/main/py/storm/__init__.py | 1 +
jstorm-core/src/main/py/storm/constants.py | 11 +
jstorm-core/src/main/py/storm/ttypes.py | 4456 +++
jstorm-core/src/main/resources/defaults.yaml | 342 +
jstorm-core/src/main/resources/logback-test.xml | 17 +
jstorm-core/src/main/resources/version | 1 +
.../com/alibaba/jstorm/cache/RocksDBTest.java | 466 +
.../jstorm/message/context/ContextTest.java | 60 +
.../jstorm/message/netty/NettyUnitTest.java | 794 +
.../alibaba/jstorm/message/zmq/ZmqUnitTest.java | 317 +
.../com/alibaba/jstorm/metric/MetricTest.java | 380 +
.../superivosr/deamon/HttpserverTest.java | 43 +
.../alibaba/jstorm/topology/SingleJoinBolt.java | 132 +
.../alibaba/jstorm/topology/SingleJoinTest.java | 80 +
.../jstorm/topology/TransactionalWordsTest.java | 280 +
.../jstorm/util/queue/DisruptorTest.java | 566 +
.../alibaba/jstorm/utils/JStormUtilsTest.java | 171 +
.../com/alibaba/jstorm/utils/TestThrift.java | 31 +
jstorm-server/bin/.project | 29 -
.../bin/.settings/org.eclipse.jdt.core.prefs | 5 -
.../bin/.settings/org.eclipse.m2e.core.prefs | 4 -
jstorm-server/bin/jstorm.py | 396 -
jstorm-server/bin/start.sh | 75 -
jstorm-server/bin/stop.sh | 15 -
jstorm-server/conf/aloha_log4j.properties | 19 -
jstorm-server/conf/aloha_logback.xml | 14 -
jstorm-server/conf/cgconfig.conf | 18 -
jstorm-server/conf/jstorm.log4j.properties | 50 -
jstorm-server/conf/jstorm.logback.xml | 78 -
jstorm-server/conf/storm.yaml | 83 -
jstorm-server/pom.xml | 87 -
.../main/java/backtype/storm/LocalCluster.java | 238 -
.../java/backtype/storm/LocalClusterMap.java | 111 -
.../src/main/java/backtype/storm/LocalDRPC.java | 87 -
.../main/java/backtype/storm/LocalUtils.java | 114 -
.../callback/impl/ActiveTransitionCallback.java | 19 -
.../impl/DelayStatusTransitionCallback.java | 96 -
.../impl/DoRebalanceTransitionCallback.java | 54 -
.../impl/InactiveTransitionCallback.java | 21 -
.../callback/impl/KillTransitionCallback.java | 21 -
.../impl/ReassignTransitionCallback.java | 49 -
.../impl/RebalanceTransitionCallback.java | 27 -
.../callback/impl/RemoveTransitionCallback.java | 51 -
.../com/alibaba/jstorm/cluster/Cluster.java | 339 -
.../java/com/alibaba/jstorm/cluster/Common.java | 691 -
.../alibaba/jstorm/cluster/DaemonCommon.java | 5 -
.../com/alibaba/jstorm/cluster/StormBase.java | 114 -
.../jstorm/cluster/StormClusterState.java | 160 -
.../com/alibaba/jstorm/cluster/StormConfig.java | 476 -
.../alibaba/jstorm/cluster/StormMonitor.java | 33 -
.../com/alibaba/jstorm/cluster/StormStatus.java | 106 -
.../jstorm/cluster/StormZkClusterState.java | 823 -
.../alibaba/jstorm/container/CgroupCenter.java | 204 -
.../jstorm/container/CgroupOperation.java | 29 -
.../alibaba/jstorm/container/CgroupUtils.java | 158 -
.../com/alibaba/jstorm/container/Constants.java | 13 -
.../com/alibaba/jstorm/container/Hierarchy.java | 92 -
.../com/alibaba/jstorm/container/SubSystem.java | 53 -
.../alibaba/jstorm/container/SubSystemType.java | 31 -
.../jstorm/container/SystemOperation.java | 58 -
.../jstorm/container/cgroup/CgroupCommon.java | 229 -
.../container/cgroup/CgroupCommonOperation.java | 31 -
.../container/cgroup/CgroupCoreFactory.java | 60 -
.../alibaba/jstorm/container/cgroup/Device.java | 53 -
.../jstorm/container/cgroup/core/BlkioCore.java | 274 -
.../container/cgroup/core/CgroupCore.java | 10 -
.../jstorm/container/cgroup/core/CpuCore.java | 132 -
.../container/cgroup/core/CpuacctCore.java | 59 -
.../container/cgroup/core/CpusetCore.java | 232 -
.../container/cgroup/core/DevicesCore.java | 170 -
.../container/cgroup/core/FreezerCore.java | 50 -
.../container/cgroup/core/MemoryCore.java | 204 -
.../container/cgroup/core/NetClsCore.java | 57 -
.../container/cgroup/core/NetPrioCore.java | 54 -
.../jstorm/daemon/nimbus/DefaultInimbus.java | 55 -
.../jstorm/daemon/nimbus/NimbusData.java | 234 -
.../jstorm/daemon/nimbus/NimbusServer.java | 405 -
.../jstorm/daemon/nimbus/NimbusUtils.java | 798 -
.../jstorm/daemon/nimbus/ServiceHandler.java | 1353 -
.../jstorm/daemon/nimbus/StatusTransition.java | 258 -
.../jstorm/daemon/nimbus/StatusType.java | 48 -
.../jstorm/daemon/nimbus/TopologyAssign.java | 834 -
.../daemon/nimbus/TopologyAssignEvent.java | 91 -
.../daemon/nimbus/TransitionZkCallback.java | 24 -
.../jstorm/daemon/supervisor/CgroupManager.java | 102 -
.../jstorm/daemon/supervisor/Heartbeat.java | 127 -
.../jstorm/daemon/supervisor/Httpserver.java | 460 -
.../jstorm/daemon/supervisor/SandBoxMaker.java | 195 -
.../jstorm/daemon/supervisor/ShutdownWork.java | 140 -
.../daemon/supervisor/StateHeartbeat.java | 36 -
.../jstorm/daemon/supervisor/Supervisor.java | 249 -
.../daemon/supervisor/SupervisorDaemon.java | 13 -
.../daemon/supervisor/SupervisorInfo.java | 153 -
.../daemon/supervisor/SupervisorManger.java | 177 -
.../daemon/supervisor/SyncProcessEvent.java | 882 -
.../daemon/supervisor/SyncSupervisorEvent.java | 448 -
.../jstorm/daemon/worker/BatchTupleRunable.java | 127 -
.../jstorm/daemon/worker/ContextMaker.java | 107 -
.../jstorm/daemon/worker/DrainerRunable.java | 55 -
.../jstorm/daemon/worker/ProcessSimulator.java | 81 -
.../jstorm/daemon/worker/RefreshActive.java | 138 -
.../daemon/worker/RefreshConnections.java | 214 -
.../com/alibaba/jstorm/daemon/worker/State.java | 11 -
.../daemon/worker/VirtualPortDispatch.java | 84 -
.../alibaba/jstorm/daemon/worker/Worker.java | 478 -
.../jstorm/daemon/worker/WorkerData.java | 459 -
.../jstorm/daemon/worker/WorkerHaltRunable.java | 13 -
.../jstorm/daemon/worker/WorkerHeartbeat.java | 72 -
.../jstorm/daemon/worker/WorkerMetricInfo.java | 156 -
.../jstorm/daemon/worker/WorkerShutdown.java | 166 -
.../daemon/worker/hearbeat/SyncContainerHb.java | 361 -
.../worker/hearbeat/WorkerHeartbeatRunable.java | 101 -
.../daemon/worker/metrics/AlimonitorClient.java | 267 -
.../daemon/worker/metrics/MetricKVMsg.java | 254 -
.../daemon/worker/metrics/MetricReporter.java | 135 -
.../daemon/worker/metrics/MetricSendClient.java | 18 -
.../worker/metrics/StormMetricReporter.java | 433 -
.../worker/metrics/TopoCommStatsInfo.java | 229 -
.../worker/metrics/UploadMetricFromZK.java | 242 -
.../worker/metrics/UploadSupervMetric.java | 235 -
.../daemon/worker/timer/RotatingMapTrigger.java | 64 -
.../daemon/worker/timer/TickTupleTrigger.java | 39 -
.../daemon/worker/timer/TimerTrigger.java | 118 -
.../com/alibaba/jstorm/drpc/ClearThread.java | 66 -
.../main/java/com/alibaba/jstorm/drpc/Drpc.java | 294 -
.../com/alibaba/jstorm/event/EventManager.java | 11 -
.../alibaba/jstorm/event/EventManagerImp.java | 79 -
.../jstorm/event/EventManagerImpExecute.java | 57 -
.../jstorm/event/EventManagerPusher.java | 47 -
.../jstorm/event/EventManagerZkPusher.java | 25 -
.../jstorm/message/netty/ControlMessage.java | 62 -
.../jstorm/message/netty/MessageBatch.java | 178 -
.../jstorm/message/netty/MessageDecoder.java | 147 -
.../jstorm/message/netty/MessageEncoder.java | 23 -
.../jstorm/message/netty/NettyClient.java | 450 -
.../jstorm/message/netty/NettyClientAsync.java | 339 -
.../jstorm/message/netty/NettyClientSync.java | 279 -
.../jstorm/message/netty/NettyContext.java | 115 -
.../message/netty/NettyRenameThreadFactory.java | 35 -
.../jstorm/message/netty/NettyServer.java | 199 -
.../jstorm/message/netty/ReconnectRunnable.java | 55 -
.../message/netty/StormClientHandler.java | 87 -
.../netty/StormClientPipelineFactory.java | 27 -
.../message/netty/StormServerHandler.java | 99 -
.../netty/StormServerPipelineFactory.java | 27 -
.../jstorm/message/zeroMq/MQContext.java | 132 -
.../jstorm/message/zeroMq/PacketPair.java | 73 -
.../message/zeroMq/ZMQRecvConnection.java | 105 -
.../message/zeroMq/ZMQSendConnection.java | 92 -
.../alibaba/jstorm/message/zeroMq/ZeroMq.java | 112 -
.../jstorm/queue/disruptor/JstormEvent.java | 23 -
.../queue/disruptor/JstormEventHandler.java | 29 -
.../jstorm/queue/disruptor/JstormProducer.java | 45 -
.../alibaba/jstorm/schedule/CleanRunnable.java | 65 -
.../jstorm/schedule/DelayEventRunnable.java | 25 -
.../jstorm/schedule/FollowerRunnable.java | 269 -
.../jstorm/schedule/IToplogyScheduler.java | 14 -
.../jstorm/schedule/MonitorRunnable.java | 101 -
.../jstorm/schedule/TopologyAssignContext.java | 151 -
.../DefaultTopologyAssignContext.java | 203 -
.../DefaultTopologyScheduler.java | 162 -
.../default_assign/ResourceWorkerSlot.java | 139 -
.../Selector/AbstractSelector.java | 54 -
.../Selector/ComponentNumSelector.java | 37 -
.../Selector/InputComponentNumSelector.java | 36 -
.../default_assign/Selector/Selector.java | 10 -
.../Selector/TotalTaskNumSelector.java | 35 -
.../Selector/WorkerComparator.java | 15 -
.../schedule/default_assign/TaskGanker.java | 209 -
.../default_assign/TaskGankerContext.java | 93 -
.../schedule/default_assign/WorkerMaker.java | 300 -
.../alibaba/jstorm/stats/CommonStatsData.java | 277 -
.../jstorm/stats/CommonStatsRolling.java | 332 -
.../com/alibaba/jstorm/stats/StatFunction.java | 129 -
.../jstorm/stats/incval/IncValExtractor.java | 22 -
.../jstorm/stats/incval/IncValMerger.java | 38 -
.../jstorm/stats/incval/IncValUpdater.java | 36 -
.../jstorm/stats/keyAvg/KeyAvgExtractor.java | 27 -
.../jstorm/stats/keyAvg/KeyAvgMerge.java | 43 -
.../jstorm/stats/keyAvg/KeyAvgUpdater.java | 34 -
.../jstorm/stats/rolling/RollingWindow.java | 165 -
.../jstorm/stats/rolling/RollingWindowSet.java | 124 -
.../jstorm/stats/rolling/UpdateParams.java | 23 -
.../com/alibaba/jstorm/task/Assignment.java | 172 -
.../com/alibaba/jstorm/task/AssignmentBak.java | 38 -
.../alibaba/jstorm/task/LocalAssignment.java | 130 -
.../alibaba/jstorm/task/ShutdownableDameon.java | 10 -
.../main/java/com/alibaba/jstorm/task/Task.java | 292 -
.../java/com/alibaba/jstorm/task/TaskInfo.java | 58 -
.../com/alibaba/jstorm/task/TaskMetricInfo.java | 152 -
.../alibaba/jstorm/task/TaskShutdownDameon.java | 151 -
.../com/alibaba/jstorm/task/TaskStatus.java | 41 -
.../com/alibaba/jstorm/task/TaskTransfer.java | 145 -
.../com/alibaba/jstorm/task/TkHbCacheTime.java | 48 -
.../com/alibaba/jstorm/task/UptimeComputer.java | 21 -
.../alibaba/jstorm/task/acker/AckObject.java | 19 -
.../com/alibaba/jstorm/task/acker/Acker.java | 145 -
.../jstorm/task/comm/TaskSendTargets.java | 133 -
.../com/alibaba/jstorm/task/comm/TupleInfo.java | 56 -
.../jstorm/task/comm/UnanchoredSend.java | 37 -
.../jstorm/task/error/ITaskReportErr.java | 11 -
.../alibaba/jstorm/task/error/TaskError.java | 38 -
.../jstorm/task/error/TaskErrorRunable.java | 31 -
.../jstorm/task/error/TaskReportError.java | 41 -
.../task/error/TaskReportErrorAndDie.java | 26 -
.../jstorm/task/execute/BaseExecutors.java | 295 -
.../jstorm/task/execute/BoltCollector.java | 236 -
.../jstorm/task/execute/BoltExecutors.java | 210 -
.../jstorm/task/execute/spout/AckSpoutMsg.java | 60 -
.../jstorm/task/execute/spout/FailSpoutMsg.java | 55 -
.../jstorm/task/execute/spout/IAckMsg.java | 5 -
.../spout/MultipleThreadSpoutExecutors.java | 116 -
.../spout/SingleThreadSpoutExecutors.java | 91 -
.../task/execute/spout/SpoutCollector.java | 194 -
.../task/execute/spout/SpoutExecutors.java | 260 -
.../execute/spout/SpoutTimeoutCallBack.java | 54 -
.../jstorm/task/execute/spout/TimerRatio.java | 58 -
.../alibaba/jstorm/task/group/GrouperType.java | 11 -
.../jstorm/task/group/MkCustomGrouper.java | 34 -
.../jstorm/task/group/MkFieldsGrouper.java | 43 -
.../alibaba/jstorm/task/group/MkGrouper.java | 183 -
.../alibaba/jstorm/task/group/MkLocalFirst.java | 132 -
.../jstorm/task/group/MkLocalShuffer.java | 55 -
.../alibaba/jstorm/task/group/MkShuffer.java | 38 -
.../com/alibaba/jstorm/task/group/Shuffer.java | 31 -
.../jstorm/task/heartbeat/TaskHeartbeat.java | 85 -
.../task/heartbeat/TaskHeartbeatRunable.java | 147 -
.../jstorm/task/heartbeat/TaskStats.java | 21 -
.../alibaba/jstorm/utils/DisruptorRunable.java | 89 -
.../utils/FailedAssignTopologyException.java | 22 -
.../alibaba/jstorm/utils/JStormServerUtils.java | 132 -
.../java/com/alibaba/jstorm/utils/Thrift.java | 484 -
jstorm-server/src/main/resources/defaults.yaml | 281 -
.../jstorm/message/context/ContextTest.java | 43 -
.../jstorm/message/netty/NettyUnitTest.java | 781 -
.../alibaba/jstorm/message/zmq/ZmqUnitTest.java | 299 -
.../superivosr/deamon/HttpserverTest.java | 25 -
.../alibaba/jstorm/topology/SingleJoinBolt.java | 128 -
.../alibaba/jstorm/topology/SingleJoinTest.java | 79 -
.../jstorm/topology/TransactionalWordsTest.java | 274 -
.../alibaba/jstorm/utils/JStormUtilsTest.java | 158 -
.../src/test/resources/log4j.properties | 47 -
jstorm-ui/.classpath | 32 +
jstorm-ui/.gitignore | 1 +
jstorm-ui/.project | 42 +
jstorm-ui/.settings/.jsdtscope | 13 +
.../.settings/org.eclipse.core.resources.prefs | 4 +
jstorm-ui/.settings/org.eclipse.jdt.core.prefs | 8 +
jstorm-ui/.settings/org.eclipse.m2e.core.prefs | 4 +
.../.settings/org.eclipse.wst.common.component | 13 +
...ipse.wst.common.project.facet.core.prefs.xml | 12 +
...rg.eclipse.wst.common.project.facet.core.xml | 9 +
.../org.eclipse.wst.jsdt.ui.superType.container | 1 +
.../org.eclipse.wst.jsdt.ui.superType.name | 1 +
.../.settings/org.eclipse.wst.validation.prefs | 2 +
jstorm-ui/nb-configuration.xml | 0
jstorm-ui/pom.xml | 246 +-
.../alibaba/jstorm/ui/DescendComparator.java | 67 +-
.../alibaba/jstorm/ui/NimbusClientManager.java | 113 +
.../main/java/com/alibaba/jstorm/ui/UIDef.java | 114 +
.../java/com/alibaba/jstorm/ui/UIMetrics.java | 62 +
.../java/com/alibaba/jstorm/ui/UIUtils.java | 1127 +-
.../alibaba/jstorm/ui/model/ClusterInfo.java | 45 -
.../alibaba/jstorm/ui/model/ClusterSumm.java | 104 -
.../com/alibaba/jstorm/ui/model/ColumnData.java | 59 +
.../alibaba/jstorm/ui/model/ComponentInput.java | 87 -
.../jstorm/ui/model/ComponentOutput.java | 51 -
.../alibaba/jstorm/ui/model/ComponentStats.java | 85 -
.../jstorm/ui/model/ComponentSummary.java | 45 -
.../alibaba/jstorm/ui/model/ComponentTask.java | 96 -
.../com/alibaba/jstorm/ui/model/Components.java | 52 -
.../alibaba/jstorm/ui/model/ErrorSummary.java | 37 -
.../com/alibaba/jstorm/ui/model/LinkData.java | 65 +
.../alibaba/jstorm/ui/model/LogPageIndex.java | 28 -
.../alibaba/jstorm/ui/model/NimbusSlave.java | 67 -
.../alibaba/jstorm/ui/model/PageGenerator.java | 32 +
.../com/alibaba/jstorm/ui/model/PageIndex.java | 151 +
.../alibaba/jstorm/ui/model/SpoutOutput.java | 90 -
.../alibaba/jstorm/ui/model/SupervisorSumm.java | 78 -
.../com/alibaba/jstorm/ui/model/TableData.java | 41 +
.../alibaba/jstorm/ui/model/TaskMetrics.java | 151 -
.../com/alibaba/jstorm/ui/model/TaskSumm.java | 84 -
.../alibaba/jstorm/ui/model/TopologySumm.java | 78 -
.../jstorm/ui/model/WinComponentStats.java | 24 -
.../alibaba/jstorm/ui/model/WorkerMetrics.java | 183 -
.../com/alibaba/jstorm/ui/model/WorkerSumm.java | 114 -
.../alibaba/jstorm/ui/model/data/BoltPage.java | 391 -
.../jstorm/ui/model/data/ClusterPage.java | 101 -
.../alibaba/jstorm/ui/model/data/ConfPage.java | 180 -
.../jstorm/ui/model/data/JStackPage.java | 154 -
.../jstorm/ui/model/data/ListLogPage.java | 237 -
.../alibaba/jstorm/ui/model/data/LogPage.java | 409 -
.../alibaba/jstorm/ui/model/data/MainPage.java | 208 -
.../com/alibaba/jstorm/ui/model/data/Param.java | 100 -
.../alibaba/jstorm/ui/model/data/SpoutPage.java | 398 -
.../jstorm/ui/model/data/SupervisorPage.java | 176 -
.../alibaba/jstorm/ui/model/data/Taskpage.java | 159 -
.../jstorm/ui/model/data/TopologyPage.java | 295 -
.../jstorm/ui/model/pages/ClusterPage.java | 324 +
.../jstorm/ui/model/pages/ComponentPage.java | 473 +
.../alibaba/jstorm/ui/model/pages/ConfPage.java | 167 +
.../alibaba/jstorm/ui/model/pages/HomePage.java | 182 +
.../jstorm/ui/model/pages/JStackPage.java | 135 +
.../jstorm/ui/model/pages/ListLogsPage.java | 232 +
.../alibaba/jstorm/ui/model/pages/LogPage.java | 300 +
.../jstorm/ui/model/pages/NettyPage.java | 131 +
.../jstorm/ui/model/pages/SupervisorPage.java | 281 +
.../jstorm/ui/model/pages/TablePage.java | 154 +
.../jstorm/ui/model/pages/TopologyPage.java | 211 +
.../jstorm/ui/model/pages/WindowTablePage.java | 105 +
jstorm-ui/src/main/resources/defaults.yaml | 235 -
jstorm-ui/src/main/resources/log4j.properties | 0
jstorm-ui/src/main/resources/logback-test.xml | 49 +
jstorm-ui/src/main/webapp/META-INF/context.xml | 0
.../src/main/webapp/WEB-INF/faces-config.xml | 0
jstorm-ui/src/main/webapp/WEB-INF/web.xml | 0
jstorm-ui/src/main/webapp/assets/css/aloha.css | 25 +
.../main/webapp/assets/css/bootstrap-theme.css | 476 +
.../webapp/assets/css/bootstrap-theme.css.map | 1 +
.../webapp/assets/css/bootstrap-theme.min.css | 5 +
.../src/main/webapp/assets/css/bootstrap.css | 6584 ++++
.../main/webapp/assets/css/bootstrap.css.map | 1 +
.../main/webapp/assets/css/bootstrap.min.css | 5 +
.../fonts/glyphicons-halflings-regular.eot | Bin 0 -> 20127 bytes
.../fonts/glyphicons-halflings-regular.svg | 288 +
.../fonts/glyphicons-halflings-regular.ttf | Bin 0 -> 45404 bytes
.../fonts/glyphicons-halflings-regular.woff | Bin 0 -> 23424 bytes
.../fonts/glyphicons-halflings-regular.woff2 | Bin 0 -> 18028 bytes
.../src/main/webapp/assets/js/bootstrap.js | 2317 ++
.../src/main/webapp/assets/js/bootstrap.min.js | 7 +
.../src/main/webapp/assets/js/jquery.min.js | 5 +
jstorm-ui/src/main/webapp/assets/js/npm.js | 13 +
jstorm-ui/src/main/webapp/bolt.xhtml | 402 -
jstorm-ui/src/main/webapp/cluster.xhtml | 274 -
jstorm-ui/src/main/webapp/clusters.xhtml | 137 +-
jstorm-ui/src/main/webapp/conf.xhtml | 26 -
jstorm-ui/src/main/webapp/jstack.xhtml | 29 -
jstorm-ui/src/main/webapp/listlog.xhtml | 104 -
jstorm-ui/src/main/webapp/log.xhtml | 127 +-
jstorm-ui/src/main/webapp/spout.xhtml | 400 -
jstorm-ui/src/main/webapp/supervisor.xhtml | 258 -
jstorm-ui/src/main/webapp/table.xhtml | 89 +
jstorm-ui/src/main/webapp/task.xhtml | 92 -
jstorm-ui/src/main/webapp/topology.xhtml | 360 -
jstorm-ui/src/main/webapp/windowtable.xhtml | 130 +
other/genthrift.sh | 11 +-
other/storm.thrift | 236 +-
other/storm.thrift.bak | 343 +
pom.xml | 173 +-
release.xml | 22 +-
1819 files changed, 182933 insertions(+), 134886 deletions(-)
----------------------------------------------------------------------