storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ptgo...@apache.org
Subject [18/18] git commit: Merge pull request #767 from ptgoetz/apache-headers
Date Fri, 13 Dec 2013 17:15:02 GMT
Merge pull request #767 from ptgoetz/apache-headers

Add Apache License Headers

Project: http://git-wip-us.apache.org/repos/asf/incubator-storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-storm/commit/7e40f9f6
Tree: http://git-wip-us.apache.org/repos/asf/incubator-storm/tree/7e40f9f6
Diff: http://git-wip-us.apache.org/repos/asf/incubator-storm/diff/7e40f9f6

Branch: refs/heads/master
Commit: 7e40f9f619b87537792f06040e354e677662459e
Parents: 51f8a54 639201c
Author: P. Taylor Goetz <ptgoetz@gmail.com>
Authored: Thu Dec 12 17:21:37 2013 -0800
Committer: P. Taylor Goetz <ptgoetz@gmail.com>
Committed: Thu Dec 12 17:21:37 2013 -0800

----------------------------------------------------------------------
 LICENSE                                         | 285 +++++++++++++++++++
 LICENSE.html                                    | 261 -----------------
 NOTICE                                          |  12 +-
 README.markdown                                 |  23 +-
 bin/build_modules.sh                            |  16 ++
 bin/build_release.sh                            |  17 ++
 bin/install_zmq.sh                              |  17 ++
 bin/javadoc.sh                                  |  16 ++
 bin/storm                                       |  16 ++
 bin/to_maven.sh                                 |  17 ++
 conf/defaults.yaml                              |  18 ++
 conf/jaas_digest.conf                           |  18 ++
 conf/logback.xml                                |  17 +-
 conf/storm.yaml.example                         |  16 ++
 logback/cluster.xml                             |  18 +-
 project.clj                                     |  15 +
 storm-console-logging/project.clj               |  15 +
 storm-core/project.clj                          |  15 +
 .../src/clj/backtype/storm/LocalCluster.clj     |  15 +
 storm-core/src/clj/backtype/storm/LocalDRPC.clj |  15 +
 storm-core/src/clj/backtype/storm/bootstrap.clj |  15 +
 storm-core/src/clj/backtype/storm/clojure.clj   |  15 +
 storm-core/src/clj/backtype/storm/cluster.clj   |  15 +
 .../src/clj/backtype/storm/command/activate.clj |  15 +
 .../clj/backtype/storm/command/config_value.clj |  15 +
 .../clj/backtype/storm/command/deactivate.clj   |  15 +
 .../backtype/storm/command/dev_zookeeper.clj    |  15 +
 .../backtype/storm/command/kill_topology.clj    |  15 +
 .../src/clj/backtype/storm/command/list.clj     |  15 +
 .../clj/backtype/storm/command/rebalance.clj    |  15 +
 .../backtype/storm/command/shell_submission.clj |  15 +
 storm-core/src/clj/backtype/storm/config.clj    |  15 +
 .../src/clj/backtype/storm/daemon/acker.clj     |  15 +
 .../backtype/storm/daemon/builtin_metrics.clj   |  15 +
 .../src/clj/backtype/storm/daemon/common.clj    |  15 +
 .../src/clj/backtype/storm/daemon/drpc.clj      |  19 +-
 .../src/clj/backtype/storm/daemon/executor.clj  |  15 +
 .../src/clj/backtype/storm/daemon/logviewer.clj |  15 +
 .../src/clj/backtype/storm/daemon/nimbus.clj    |  15 +
 .../clj/backtype/storm/daemon/supervisor.clj    |  15 +
 .../src/clj/backtype/storm/daemon/task.clj      |  15 +
 .../src/clj/backtype/storm/daemon/worker.clj    |  15 +
 storm-core/src/clj/backtype/storm/disruptor.clj |  15 +
 storm-core/src/clj/backtype/storm/event.clj     |  15 +
 storm-core/src/clj/backtype/storm/log.clj       |  15 +
 .../src/clj/backtype/storm/messaging/loader.clj |  15 +
 .../src/clj/backtype/storm/messaging/local.clj  |  15 +
 .../src/clj/backtype/storm/messaging/zmq.clj    |  15 +
 .../src/clj/backtype/storm/metric/testing.clj   |  15 +
 .../clj/backtype/storm/process_simulator.clj    |  15 +
 .../storm/scheduler/DefaultScheduler.clj        |  15 +
 .../backtype/storm/scheduler/EvenScheduler.clj  |  15 +
 .../storm/scheduler/IsolationScheduler.clj      |  15 +
 storm-core/src/clj/backtype/storm/stats.clj     |  15 +
 storm-core/src/clj/backtype/storm/testing.clj   |  15 +
 storm-core/src/clj/backtype/storm/testing4j.clj |  15 +
 storm-core/src/clj/backtype/storm/thrift.clj    |  15 +
 storm-core/src/clj/backtype/storm/timer.clj     |  15 +
 storm-core/src/clj/backtype/storm/tuple.clj     |  15 +
 storm-core/src/clj/backtype/storm/ui/core.clj   |  15 +
 .../src/clj/backtype/storm/ui/helpers.clj       |  15 +
 storm-core/src/clj/backtype/storm/util.clj      |  15 +
 storm-core/src/clj/backtype/storm/zookeeper.clj |  15 +
 storm-core/src/clj/storm/trident/testing.clj    |  15 +
 storm-core/src/clj/zilch/mq.clj                 |  15 +
 storm-core/src/dev/resources/tester_bolt.py     |  18 ++
 storm-core/src/dev/resources/tester_bolt.rb     |  18 ++
 storm-core/src/dev/resources/tester_spout.py    |  18 ++
 storm-core/src/dev/resources/tester_spout.rb    |  17 ++
 storm-core/src/genthrift.sh                     |  16 ++
 storm-core/src/jvm/backtype/storm/Config.java   |  17 ++
 .../jvm/backtype/storm/ConfigValidation.java    |  17 ++
 .../src/jvm/backtype/storm/Constants.java       |  17 ++
 .../src/jvm/backtype/storm/ILocalCluster.java   |  17 ++
 .../src/jvm/backtype/storm/ILocalDRPC.java      |  17 ++
 .../src/jvm/backtype/storm/StormSubmitter.java  |  17 ++
 .../jvm/backtype/storm/clojure/ClojureBolt.java |  17 ++
 .../backtype/storm/clojure/ClojureSpout.java    |  17 ++
 .../backtype/storm/clojure/RichShellBolt.java   |  17 ++
 .../backtype/storm/clojure/RichShellSpout.java  |  17 ++
 .../storm/coordination/BatchBoltExecutor.java   |  17 ++
 .../coordination/BatchOutputCollector.java      |  17 ++
 .../coordination/BatchOutputCollectorImpl.java  |  17 ++
 .../coordination/BatchSubtopologyBuilder.java   |  17 ++
 .../storm/coordination/CoordinatedBolt.java     |  17 ++
 .../backtype/storm/coordination/IBatchBolt.java |  17 ++
 .../jvm/backtype/storm/daemon/Shutdownable.java |  17 ++
 .../storm/drpc/DRPCInvocationsClient.java       |  17 ++
 .../src/jvm/backtype/storm/drpc/DRPCSpout.java  |  17 ++
 .../src/jvm/backtype/storm/drpc/JoinResult.java |  17 ++
 .../jvm/backtype/storm/drpc/KeyedFairBolt.java  |  17 ++
 .../storm/drpc/LinearDRPCInputDeclarer.java     |  17 ++
 .../storm/drpc/LinearDRPCTopologyBuilder.java   |  17 ++
 .../jvm/backtype/storm/drpc/PrepareRequest.java |  17 ++
 .../jvm/backtype/storm/drpc/ReturnResults.java  |  17 ++
 .../storm/generated/AlreadyAliveException.java  |  17 ++
 .../src/jvm/backtype/storm/generated/Bolt.java  |  17 ++
 .../jvm/backtype/storm/generated/BoltStats.java |  17 ++
 .../storm/generated/ClusterSummary.java         |  17 ++
 .../storm/generated/ComponentCommon.java        |  17 ++
 .../storm/generated/ComponentObject.java        |  17 ++
 .../storm/generated/DRPCExecutionException.java |  17 ++
 .../backtype/storm/generated/DRPCRequest.java   |  17 ++
 .../storm/generated/DistributedRPC.java         |  17 ++
 .../generated/DistributedRPCInvocations.java    |  17 ++
 .../jvm/backtype/storm/generated/ErrorInfo.java |  17 ++
 .../backtype/storm/generated/ExecutorInfo.java  |  17 ++
 .../storm/generated/ExecutorSpecificStats.java  |  17 ++
 .../backtype/storm/generated/ExecutorStats.java |  17 ++
 .../storm/generated/ExecutorSummary.java        |  17 ++
 .../storm/generated/GlobalStreamId.java         |  17 ++
 .../jvm/backtype/storm/generated/Grouping.java  |  17 ++
 .../generated/InvalidTopologyException.java     |  17 ++
 .../backtype/storm/generated/JavaObject.java    |  17 ++
 .../backtype/storm/generated/JavaObjectArg.java |  17 ++
 .../backtype/storm/generated/KillOptions.java   |  17 ++
 .../jvm/backtype/storm/generated/Nimbus.java    |  17 ++
 .../storm/generated/NotAliveException.java      |  17 ++
 .../backtype/storm/generated/NullStruct.java    |  17 ++
 .../storm/generated/RebalanceOptions.java       |  17 ++
 .../storm/generated/ShellComponent.java         |  17 ++
 .../jvm/backtype/storm/generated/SpoutSpec.java |  17 ++
 .../backtype/storm/generated/SpoutStats.java    |  17 ++
 .../storm/generated/StateSpoutSpec.java         |  17 ++
 .../backtype/storm/generated/StormTopology.java |  17 ++
 .../backtype/storm/generated/StreamInfo.java    |  17 ++
 .../backtype/storm/generated/SubmitOptions.java |  17 ++
 .../storm/generated/SupervisorSummary.java      |  17 ++
 .../backtype/storm/generated/TopologyInfo.java  |  17 ++
 .../storm/generated/TopologyInitialStatus.java  |  17 ++
 .../storm/generated/TopologySummary.java        |  17 ++
 .../storm/grouping/CustomStreamGrouping.java    |  17 ++
 .../jvm/backtype/storm/hooks/BaseTaskHook.java  |  17 ++
 .../src/jvm/backtype/storm/hooks/ITaskHook.java |  17 ++
 .../backtype/storm/hooks/info/BoltAckInfo.java  |  17 ++
 .../storm/hooks/info/BoltExecuteInfo.java       |  17 ++
 .../backtype/storm/hooks/info/BoltFailInfo.java |  17 ++
 .../jvm/backtype/storm/hooks/info/EmitInfo.java |  17 ++
 .../backtype/storm/hooks/info/SpoutAckInfo.java |  17 ++
 .../storm/hooks/info/SpoutFailInfo.java         |  17 ++
 .../backtype/storm/messaging/IConnection.java   |  17 ++
 .../jvm/backtype/storm/messaging/IContext.java  |  17 ++
 .../backtype/storm/messaging/TaskMessage.java   |  17 ++
 .../storm/messaging/TransportFactory.java       |  17 ++
 .../storm/metric/LoggingMetricsConsumer.java    |  17 ++
 .../storm/metric/MetricsConsumerBolt.java       |  17 ++
 .../jvm/backtype/storm/metric/SystemBolt.java   |  17 ++
 .../storm/metric/api/AssignableMetric.java      |  17 ++
 .../storm/metric/api/CombinedMetric.java        |  17 ++
 .../backtype/storm/metric/api/CountMetric.java  |  17 ++
 .../backtype/storm/metric/api/ICombiner.java    |  17 ++
 .../jvm/backtype/storm/metric/api/IMetric.java  |  17 ++
 .../storm/metric/api/IMetricsConsumer.java      |  17 ++
 .../jvm/backtype/storm/metric/api/IReducer.java |  17 ++
 .../storm/metric/api/IStatefulObject.java       |  17 ++
 .../backtype/storm/metric/api/MeanReducer.java  |  17 ++
 .../storm/metric/api/MultiCountMetric.java      |  17 ++
 .../storm/metric/api/MultiReducedMetric.java    |  17 ++
 .../storm/metric/api/ReducedMetric.java         |  17 ++
 .../backtype/storm/metric/api/StateMetric.java  |  17 ++
 .../storm/nimbus/DefaultTopologyValidator.java  |  17 ++
 .../storm/nimbus/ITopologyValidator.java        |  17 ++
 .../backtype/storm/planner/CompoundSpout.java   |  17 ++
 .../backtype/storm/planner/CompoundTask.java    |  17 ++
 .../jvm/backtype/storm/planner/TaskBundle.java  |  17 ++
 .../jvm/backtype/storm/scheduler/Cluster.java   |  17 ++
 .../storm/scheduler/ExecutorDetails.java        |  91 +++---
 .../jvm/backtype/storm/scheduler/INimbus.java   |  17 ++
 .../backtype/storm/scheduler/IScheduler.java    |  17 ++
 .../backtype/storm/scheduler/ISupervisor.java   |  17 ++
 .../storm/scheduler/SchedulerAssignment.java    |  97 ++++---
 .../scheduler/SchedulerAssignmentImpl.java      | 201 +++++++------
 .../storm/scheduler/SupervisorDetails.java      |  17 ++
 .../backtype/storm/scheduler/Topologies.java    |  97 ++++---
 .../storm/scheduler/TopologyDetails.java        |  17 ++
 .../backtype/storm/scheduler/WorkerSlot.java    |  17 ++
 .../backtype/storm/security/auth/AuthUtils.java |  17 ++
 .../storm/security/auth/IAuthorizer.java        |  17 ++
 .../storm/security/auth/ITransportPlugin.java   |  17 ++
 .../storm/security/auth/ReqContext.java         |  17 ++
 .../security/auth/SaslTransportPlugin.java      |  17 ++
 .../security/auth/SimpleTransportPlugin.java    |  17 ++
 .../storm/security/auth/ThriftClient.java       |  17 ++
 .../storm/security/auth/ThriftServer.java       |  17 ++
 .../auth/authorizer/DenyAuthorizer.java         |  17 ++
 .../auth/authorizer/NoopAuthorizer.java         |  17 ++
 .../auth/digest/ClientCallbackHandler.java      |  17 ++
 .../auth/digest/DigestSaslTransportPlugin.java  |  17 ++
 .../auth/digest/ServerCallbackHandler.java      |  17 ++
 .../serialization/BlowfishTupleSerializer.java  |  17 ++
 .../storm/serialization/DefaultKryoFactory.java |  17 ++
 .../storm/serialization/IKryoDecorator.java     |  17 ++
 .../storm/serialization/IKryoFactory.java       |  17 ++
 .../storm/serialization/ITupleDeserializer.java |  17 ++
 .../storm/serialization/ITupleSerializer.java   |  17 ++
 .../serialization/KryoTupleDeserializer.java    |  17 ++
 .../serialization/KryoTupleSerializer.java      |  17 ++
 .../serialization/KryoValuesDeserializer.java   |  17 ++
 .../serialization/KryoValuesSerializer.java     |  17 ++
 .../serialization/SerializableSerializer.java   |  17 ++
 .../serialization/SerializationFactory.java     |  17 ++
 .../types/ArrayListSerializer.java              |  17 ++
 .../serialization/types/HashMapSerializer.java  |  17 ++
 .../serialization/types/HashSetSerializer.java  |  17 ++
 .../types/ListDelegateSerializer.java           |  17 ++
 .../storm/spout/IMultiSchemableSpout.java       |  17 ++
 .../backtype/storm/spout/ISchemableSpout.java   |  17 ++
 .../src/jvm/backtype/storm/spout/ISpout.java    |  17 ++
 .../storm/spout/ISpoutOutputCollector.java      |  17 ++
 .../storm/spout/ISpoutWaitStrategy.java         |  17 ++
 .../jvm/backtype/storm/spout/MultiScheme.java   |  17 ++
 .../storm/spout/NothingEmptyEmitStrategy.java   |  17 ++
 .../backtype/storm/spout/RawMultiScheme.java    |  17 ++
 .../src/jvm/backtype/storm/spout/RawScheme.java |  17 ++
 .../src/jvm/backtype/storm/spout/Scheme.java    |  17 ++
 .../storm/spout/SchemeAsMultiScheme.java        |  17 ++
 .../jvm/backtype/storm/spout/ShellSpout.java    |  17 ++
 .../storm/spout/SleepSpoutWaitStrategy.java     |  17 ++
 .../storm/spout/SpoutOutputCollector.java       |  17 ++
 .../jvm/backtype/storm/state/IStateSpout.java   |  17 ++
 .../storm/state/IStateSpoutOutputCollector.java |  17 ++
 .../backtype/storm/state/ISubscribedState.java  |  17 ++
 .../state/ISynchronizeOutputCollector.java      |  17 ++
 .../storm/state/StateSpoutOutputCollector.java  |  17 ++
 .../storm/state/SynchronizeOutputCollector.java |  17 ++
 .../storm/task/GeneralTopologyContext.java      |  17 ++
 .../src/jvm/backtype/storm/task/IBolt.java      |  17 ++
 .../jvm/backtype/storm/task/IErrorReporter.java |  17 ++
 .../backtype/storm/task/IMetricsContext.java    |  17 ++
 .../backtype/storm/task/IOutputCollector.java   |  17 ++
 .../backtype/storm/task/OutputCollector.java    |  17 ++
 .../src/jvm/backtype/storm/task/ShellBolt.java  |  17 ++
 .../backtype/storm/task/TopologyContext.java    |  17 ++
 .../storm/task/WorkerTopologyContext.java       |  17 ++
 .../backtype/storm/testing/AckFailDelegate.java |  17 ++
 .../storm/testing/AckFailMapTracker.java        |  17 ++
 .../jvm/backtype/storm/testing/AckTracker.java  |  17 ++
 .../backtype/storm/testing/BatchNumberList.java |  17 ++
 .../storm/testing/BatchProcessWord.java         |  17 ++
 .../backtype/storm/testing/BatchRepeatA.java    |  17 ++
 .../jvm/backtype/storm/testing/BoltTracker.java |  17 ++
 .../storm/testing/CompleteTopologyParam.java    | 117 ++++----
 .../storm/testing/CountingBatchBolt.java        |  17 ++
 .../storm/testing/CountingCommitBolt.java       |  17 ++
 .../jvm/backtype/storm/testing/FeederSpout.java |  17 ++
 .../jvm/backtype/storm/testing/FixedTuple.java  |  17 ++
 .../backtype/storm/testing/FixedTupleSpout.java |  17 ++
 .../backtype/storm/testing/IdentityBolt.java    |  17 ++
 .../storm/testing/KeyedCountingBatchBolt.java   |  17 ++
 .../testing/KeyedCountingCommitterBolt.java     |  17 ++
 .../storm/testing/KeyedSummingBatchBolt.java    |  17 ++
 .../storm/testing/MemoryTransactionalSpout.java |  17 ++
 .../testing/MemoryTransactionalSpoutMeta.java   |  17 ++
 .../backtype/storm/testing/MkClusterParam.java  |  97 ++++---
 .../backtype/storm/testing/MkTupleParam.java    |  85 +++---
 .../backtype/storm/testing/MockedSources.java   | 103 ++++---
 .../jvm/backtype/storm/testing/NGrouping.java   |  17 ++
 .../storm/testing/NonRichBoltTracker.java       |  17 ++
 .../testing/OpaqueMemoryTransactionalSpout.java |  17 ++
 .../storm/testing/PrepareBatchBolt.java         |  17 ++
 .../backtype/storm/testing/SpoutTracker.java    |  17 ++
 .../storm/testing/TestAggregatesCounter.java    |  17 ++
 .../backtype/storm/testing/TestConfBolt.java    |  17 ++
 .../backtype/storm/testing/TestGlobalCount.java |  17 ++
 .../src/jvm/backtype/storm/testing/TestJob.java |  65 +++--
 .../storm/testing/TestKryoDecorator.java        |  17 ++
 .../backtype/storm/testing/TestPlannerBolt.java |  17 ++
 .../storm/testing/TestPlannerSpout.java         |  17 ++
 .../backtype/storm/testing/TestSerObject.java   |  17 ++
 .../backtype/storm/testing/TestWordCounter.java |  17 ++
 .../backtype/storm/testing/TestWordSpout.java   |  17 ++
 .../backtype/storm/testing/TrackedTopology.java |  51 ++--
 .../storm/testing/TupleCaptureBolt.java         |  17 ++
 .../topology/BaseConfigurationDeclarer.java     |  17 ++
 .../storm/topology/BasicBoltExecutor.java       |  17 ++
 .../storm/topology/BasicOutputCollector.java    |  17 ++
 .../backtype/storm/topology/BoltDeclarer.java   |  17 ++
 .../ComponentConfigurationDeclarer.java         |  17 ++
 .../storm/topology/FailedException.java         |  17 ++
 .../jvm/backtype/storm/topology/IBasicBolt.java |  17 ++
 .../storm/topology/IBasicOutputCollector.java   |  17 ++
 .../jvm/backtype/storm/topology/IComponent.java |  17 ++
 .../jvm/backtype/storm/topology/IRichBolt.java  |  17 ++
 .../jvm/backtype/storm/topology/IRichSpout.java |  17 ++
 .../storm/topology/IRichStateSpout.java         |  17 ++
 .../backtype/storm/topology/InputDeclarer.java  |  17 ++
 .../storm/topology/OutputFieldsDeclarer.java    |  17 ++
 .../storm/topology/OutputFieldsGetter.java      |  17 ++
 .../storm/topology/ReportedFailedException.java |  17 ++
 .../backtype/storm/topology/SpoutDeclarer.java  |  17 ++
 .../storm/topology/TopologyBuilder.java         |  17 ++
 .../storm/topology/base/BaseBasicBolt.java      |  17 ++
 .../storm/topology/base/BaseBatchBolt.java      |  17 ++
 .../storm/topology/base/BaseComponent.java      |  17 ++
 ...BaseOpaquePartitionedTransactionalSpout.java |  17 ++
 .../base/BasePartitionedTransactionalSpout.java |  17 ++
 .../storm/topology/base/BaseRichBolt.java       |  17 ++
 .../storm/topology/base/BaseRichSpout.java      |  17 ++
 .../topology/base/BaseTransactionalBolt.java    |  17 ++
 .../topology/base/BaseTransactionalSpout.java   |  17 ++
 .../storm/transactional/ICommitter.java         |  17 ++
 .../ICommitterTransactionalSpout.java           |  17 ++
 .../transactional/ITransactionalSpout.java      |  17 ++
 .../storm/transactional/TransactionAttempt.java |  17 ++
 .../TransactionalSpoutBatchExecutor.java        |  17 ++
 .../TransactionalSpoutCoordinator.java          |  17 ++
 .../TransactionalTopologyBuilder.java           |  17 ++
 .../IOpaquePartitionedTransactionalSpout.java   |  17 ++
 .../IPartitionedTransactionalSpout.java         |  17 ++
 ...uePartitionedTransactionalSpoutExecutor.java |  17 ++
 .../PartitionedTransactionalSpoutExecutor.java  |  17 ++
 .../state/RotatingTransactionalState.java       |  17 ++
 .../transactional/state/TransactionalState.java |  17 ++
 .../src/jvm/backtype/storm/tuple/Fields.java    |  17 ++
 .../src/jvm/backtype/storm/tuple/MessageId.java |  17 ++
 .../src/jvm/backtype/storm/tuple/Tuple.java     |  17 ++
 .../src/jvm/backtype/storm/tuple/TupleImpl.java |  17 ++
 .../src/jvm/backtype/storm/tuple/Values.java    |  17 ++
 .../storm/utils/BufferFileInputStream.java      |  17 ++
 .../backtype/storm/utils/CRC32OutputStream.java |  17 ++
 .../backtype/storm/utils/ClojureTimerTask.java  |  17 ++
 .../src/jvm/backtype/storm/utils/Container.java |  17 ++
 .../jvm/backtype/storm/utils/DRPCClient.java    |  17 ++
 .../backtype/storm/utils/DisruptorQueue.java    |  17 ++
 .../storm/utils/IndifferentAccessMap.java       |  17 ++
 .../backtype/storm/utils/InprocMessaging.java   |  17 ++
 .../storm/utils/KeyedRoundRobinQueue.java       |  17 ++
 .../jvm/backtype/storm/utils/ListDelegate.java  |  17 ++
 .../jvm/backtype/storm/utils/LocalState.java    |  17 ++
 .../jvm/backtype/storm/utils/MutableInt.java    |  17 ++
 .../jvm/backtype/storm/utils/MutableLong.java   |  17 ++
 .../jvm/backtype/storm/utils/MutableObject.java |  17 ++
 .../jvm/backtype/storm/utils/NimbusClient.java  |  17 ++
 .../storm/utils/RegisteredGlobalState.java      |  17 ++
 .../jvm/backtype/storm/utils/RotatingMap.java   |  17 ++
 .../backtype/storm/utils/ServiceRegistry.java   |  17 ++
 .../jvm/backtype/storm/utils/ShellProcess.java  |  17 ++
 .../storm/utils/ThriftTopologyUtils.java        |  17 ++
 .../src/jvm/backtype/storm/utils/Time.java      |  17 ++
 .../jvm/backtype/storm/utils/TimeCacheMap.java  |  17 ++
 .../src/jvm/backtype/storm/utils/Utils.java     |  17 ++
 .../backtype/storm/utils/VersionedStore.java    |  17 ++
 .../storm/utils/WindowedTimeThrottler.java      |  17 ++
 .../jvm/backtype/storm/utils/WritableUtils.java |  17 ++
 .../backtype/storm/utils/ZookeeperAuthInfo.java |  17 ++
 storm-core/src/jvm/storm/trident/JoinType.java  |  17 ++
 storm-core/src/jvm/storm/trident/Stream.java    |  17 ++
 .../src/jvm/storm/trident/TridentState.java     |  17 ++
 .../src/jvm/storm/trident/TridentTopology.java  |  17 ++
 .../trident/drpc/ReturnResultsReducer.java      |  17 ++
 .../fluent/ChainedAggregatorDeclarer.java       |  17 ++
 .../fluent/ChainedFullAggregatorDeclarer.java   |  17 ++
 .../ChainedPartitionAggregatorDeclarer.java     |  17 ++
 .../trident/fluent/GlobalAggregationScheme.java |  17 ++
 .../jvm/storm/trident/fluent/GroupedStream.java |  17 ++
 .../trident/fluent/IAggregatableStream.java     |  17 ++
 .../fluent/IChainedAggregatorDeclarer.java      |  17 ++
 .../jvm/storm/trident/fluent/UniqueIdGen.java   |  17 ++
 .../jvm/storm/trident/graph/GraphGrouper.java   |  17 ++
 .../src/jvm/storm/trident/graph/Group.java      |  17 ++
 .../jvm/storm/trident/operation/Aggregator.java |  17 ++
 .../jvm/storm/trident/operation/Assembly.java   |  17 ++
 .../storm/trident/operation/BaseAggregator.java |  17 ++
 .../jvm/storm/trident/operation/BaseFilter.java |  17 ++
 .../storm/trident/operation/BaseFunction.java   |  17 ++
 .../trident/operation/BaseMultiReducer.java     |  17 ++
 .../storm/trident/operation/BaseOperation.java  |  17 ++
 .../trident/operation/CombinerAggregator.java   |  17 ++
 .../storm/trident/operation/EachOperation.java  |  17 ++
 .../src/jvm/storm/trident/operation/Filter.java |  17 ++
 .../jvm/storm/trident/operation/Function.java   |  17 ++
 .../trident/operation/GroupedMultiReducer.java  |  17 ++
 .../storm/trident/operation/MultiReducer.java   |  17 ++
 .../jvm/storm/trident/operation/Operation.java  |  17 ++
 .../trident/operation/ReducerAggregator.java    |  17 ++
 .../trident/operation/TridentCollector.java     |  17 ++
 .../operation/TridentMultiReducerContext.java   |  17 ++
 .../operation/TridentOperationContext.java      |  17 ++
 .../storm/trident/operation/builtin/Count.java  |  17 ++
 .../storm/trident/operation/builtin/Debug.java  |  17 ++
 .../storm/trident/operation/builtin/Equals.java |  17 ++
 .../trident/operation/builtin/FilterNull.java   |  17 ++
 .../storm/trident/operation/builtin/FirstN.java |  17 ++
 .../storm/trident/operation/builtin/MapGet.java |  17 ++
 .../storm/trident/operation/builtin/Negate.java |  17 ++
 .../trident/operation/builtin/SnapshotGet.java  |  17 ++
 .../storm/trident/operation/builtin/Sum.java    |  17 ++
 .../operation/builtin/TupleCollectionGet.java   |  17 ++
 .../operation/impl/CaptureCollector.java        |  17 ++
 .../operation/impl/ChainedAggregatorImpl.java   |  17 ++
 .../trident/operation/impl/ChainedResult.java   |  17 ++
 .../operation/impl/CombinerAggStateUpdater.java |  17 ++
 .../impl/CombinerAggregatorCombineImpl.java     |  17 ++
 .../impl/CombinerAggregatorInitImpl.java        |  17 ++
 .../trident/operation/impl/FilterExecutor.java  |  17 ++
 .../operation/impl/GlobalBatchToPartition.java  |  17 ++
 .../trident/operation/impl/GroupCollector.java  |  17 ++
 .../operation/impl/GroupedAggregator.java       |  17 ++
 .../impl/GroupedMultiReducerExecutor.java       |  17 ++
 .../operation/impl/IdentityMultiReducer.java    |  17 ++
 .../impl/IndexHashBatchToPartition.java         |  17 ++
 .../operation/impl/JoinerMultiReducer.java      |  17 ++
 .../operation/impl/ReducerAggStateUpdater.java  |  17 ++
 .../operation/impl/ReducerAggregatorImpl.java   |  17 ++
 .../storm/trident/operation/impl/Result.java    |  17 ++
 .../operation/impl/SingleEmitAggregator.java    |  17 ++
 .../trident/operation/impl/TrueFilter.java      |  17 ++
 .../storm/trident/partition/GlobalGrouping.java |  17 ++
 .../trident/partition/IdentityGrouping.java     |  17 ++
 .../trident/partition/IndexHashGrouping.java    |  17 ++
 .../storm/trident/planner/BridgeReceiver.java   |  17 ++
 .../src/jvm/storm/trident/planner/Node.java     |  17 ++
 .../storm/trident/planner/NodeStateInfo.java    |  17 ++
 .../storm/trident/planner/PartitionNode.java    |  17 ++
 .../storm/trident/planner/ProcessorContext.java |  17 ++
 .../storm/trident/planner/ProcessorNode.java    |  17 ++
 .../jvm/storm/trident/planner/SpoutNode.java    |  17 ++
 .../storm/trident/planner/SubtopologyBolt.java  |  17 ++
 .../storm/trident/planner/TridentProcessor.java |  17 ++
 .../storm/trident/planner/TupleReceiver.java    |  17 ++
 .../planner/processor/AggregateProcessor.java   |  17 ++
 .../planner/processor/AppendCollector.java      |  17 ++
 .../planner/processor/EachProcessor.java        |  17 ++
 .../planner/processor/FreshCollector.java       |  17 ++
 .../processor/MultiReducerProcessor.java        |  17 ++
 .../processor/PartitionPersistProcessor.java    |  17 ++
 .../planner/processor/ProjectedProcessor.java   |  17 ++
 .../planner/processor/StateQueryProcessor.java  |  17 ++
 .../planner/processor/TridentContext.java       |  17 ++
 .../storm/trident/spout/BatchSpoutExecutor.java |  17 ++
 .../src/jvm/storm/trident/spout/IBatchID.java   |  17 ++
 .../jvm/storm/trident/spout/IBatchSpout.java    |  17 ++
 .../trident/spout/ICommitterTridentSpout.java   |  17 ++
 .../spout/IOpaquePartitionedTridentSpout.java   |  17 ++
 .../trident/spout/IPartitionedTridentSpout.java |  17 ++
 .../storm/trident/spout/ISpoutPartition.java    |  17 ++
 .../jvm/storm/trident/spout/ITridentSpout.java  |  17 ++
 .../OpaquePartitionedTridentSpoutExecutor.java  |  17 ++
 .../spout/PartitionedTridentSpoutExecutor.java  |  17 ++
 .../trident/spout/RichSpoutBatchExecutor.java   |  17 ++
 .../storm/trident/spout/RichSpoutBatchId.java   |  17 ++
 .../spout/RichSpoutBatchIdSerializer.java       |  17 ++
 .../trident/spout/RichSpoutBatchTriggerer.java  |  17 ++
 .../trident/spout/TridentSpoutCoordinator.java  |  17 ++
 .../trident/spout/TridentSpoutExecutor.java     |  17 ++
 .../storm/trident/state/BaseQueryFunction.java  |  17 ++
 .../storm/trident/state/BaseStateUpdater.java   |  17 ++
 .../trident/state/CombinerValueUpdater.java     |  17 ++
 .../storm/trident/state/ITupleCollection.java   |  17 ++
 .../state/JSONNonTransactionalSerializer.java   |  17 ++
 .../trident/state/JSONOpaqueSerializer.java     |  17 ++
 .../state/JSONTransactionalSerializer.java      |  17 ++
 .../jvm/storm/trident/state/OpaqueValue.java    |  17 ++
 .../jvm/storm/trident/state/QueryFunction.java  |  17 ++
 .../jvm/storm/trident/state/ReadOnlyState.java  |  17 ++
 .../trident/state/ReducerValueUpdater.java      |  17 ++
 .../src/jvm/storm/trident/state/Serializer.java |  17 ++
 .../src/jvm/storm/trident/state/State.java      |  17 ++
 .../jvm/storm/trident/state/StateFactory.java   |  17 ++
 .../src/jvm/storm/trident/state/StateSpec.java  |  17 ++
 .../src/jvm/storm/trident/state/StateType.java  |  17 ++
 .../jvm/storm/trident/state/StateUpdater.java   |  17 ++
 .../storm/trident/state/TransactionalValue.java |  17 ++
 .../jvm/storm/trident/state/ValueUpdater.java   |  17 ++
 .../trident/state/map/CachedBatchReadsMap.java  |  17 ++
 .../jvm/storm/trident/state/map/CachedMap.java  |  17 ++
 .../storm/trident/state/map/IBackingMap.java    |  17 ++
 .../state/map/MapCombinerAggStateUpdater.java   |  17 ++
 .../state/map/MapReducerAggStateUpdater.java    |  17 ++
 .../jvm/storm/trident/state/map/MapState.java   |  17 ++
 .../state/map/MicroBatchIBackingMap.java        |  17 ++
 .../trident/state/map/NonTransactionalMap.java  |  17 ++
 .../jvm/storm/trident/state/map/OpaqueMap.java  |  17 ++
 .../trident/state/map/ReadOnlyMapState.java     |  17 ++
 .../trident/state/map/SnapshottableMap.java     |  17 ++
 .../trident/state/map/TransactionalMap.java     |  17 ++
 .../state/snapshot/ReadOnlySnapshottable.java   |  17 ++
 .../trident/state/snapshot/Snapshottable.java   |  17 ++
 .../trident/testing/CountAsAggregator.java      |  17 ++
 .../storm/trident/testing/FeederBatchSpout.java |  17 ++
 .../testing/FeederCommitterBatchSpout.java      |  17 ++
 .../storm/trident/testing/FixedBatchSpout.java  |  17 ++
 .../src/jvm/storm/trident/testing/IFeeder.java  |  17 ++
 .../trident/testing/LRUMemoryMapState.java      |  17 ++
 .../storm/trident/testing/MemoryBackingMap.java |  17 ++
 .../storm/trident/testing/MemoryMapState.java   |  17 ++
 .../storm/trident/testing/MockTridentTuple.java |  17 ++
 .../src/jvm/storm/trident/testing/Split.java    |  17 ++
 .../jvm/storm/trident/testing/StringLength.java |  17 ++
 .../jvm/storm/trident/testing/TrueFilter.java   |  17 ++
 .../jvm/storm/trident/testing/TuplifyArgs.java  |  17 ++
 .../jvm/storm/trident/topology/BatchInfo.java   |  17 ++
 .../trident/topology/ITridentBatchBolt.java     |  17 ++
 .../topology/MasterBatchCoordinator.java        |  17 ++
 .../trident/topology/TransactionAttempt.java    |  17 ++
 .../trident/topology/TridentBoltExecutor.java   |  17 ++
 .../topology/TridentTopologyBuilder.java        |  17 ++
 .../state/RotatingTransactionalState.java       |  17 ++
 .../topology/state/TransactionalState.java      |  17 ++
 .../src/jvm/storm/trident/tuple/ComboList.java  |  17 ++
 .../src/jvm/storm/trident/tuple/ConsList.java   |  17 ++
 .../jvm/storm/trident/tuple/TridentTuple.java   |  17 ++
 .../storm/trident/tuple/TridentTupleView.java   |  17 ++
 .../jvm/storm/trident/tuple/ValuePointer.java   |  17 ++
 .../storm/trident/util/ErrorEdgeFactory.java    |  17 ++
 .../src/jvm/storm/trident/util/IndexedEdge.java |  17 ++
 .../src/jvm/storm/trident/util/LRUMap.java      |  17 ++
 .../jvm/storm/trident/util/TridentUtils.java    |  17 ++
 storm-core/src/multilang/py/storm.py            |  18 ++
 storm-core/src/multilang/rb/storm.rb            |  18 ++
 storm-core/src/storm.thrift                     |  23 ++
 storm-core/src/ui/public/css/style.css          |  17 ++
 storm-core/src/ui/public/js/script.js           |  17 ++
 .../test/clj/backtype/storm/clojure_test.clj    |  15 +
 .../test/clj/backtype/storm/cluster_test.clj    |  15 +
 .../test/clj/backtype/storm/config_test.clj     |  15 +
 .../test/clj/backtype/storm/drpc_test.clj       |  15 +
 .../test/clj/backtype/storm/fields_test.clj     |  15 +
 .../test/clj/backtype/storm/grouping_test.clj   |  15 +
 .../clj/backtype/storm/integration_test.clj     |  15 +
 .../clj/backtype/storm/local_state_test.clj     |  15 +
 .../test/clj/backtype/storm/messaging_test.clj  |  15 +
 .../test/clj/backtype/storm/metrics_test.clj    |  15 +
 .../test/clj/backtype/storm/multilang_test.clj  |  15 +
 .../test/clj/backtype/storm/nimbus_test.clj     |  15 +
 .../test/clj/backtype/storm/scheduler_test.clj  |  15 +
 .../storm/security/auth/AuthUtils_test.clj      |  15 +
 .../storm/security/auth/ReqContext_test.clj     |  15 +
 .../security/auth/SaslTransportPlugin_test.clj  |  15 +
 .../storm/security/auth/ThriftClient_test.clj   |  15 +
 .../storm/security/auth/ThriftServer_test.clj   |  15 +
 .../backtype/storm/security/auth/auth_test.clj  |  15 +
 .../BlowfishTupleSerializer_test.clj            |  15 +
 .../serialization/SerializationFactory_test.clj |  15 +
 .../clj/backtype/storm/serialization_test.clj   |  15 +
 .../clj/backtype/storm/subtopology_test.clj     |  15 +
 .../test/clj/backtype/storm/supervisor_test.clj |  15 +
 .../test/clj/backtype/storm/testing4j_test.clj  |  15 +
 .../test/clj/backtype/storm/tick_tuple_test.clj |  15 +
 .../clj/backtype/storm/transactional_test.clj   |  15 +
 .../test/clj/backtype/storm/tuple_test.clj      |  15 +
 .../test/clj/backtype/storm/utils_test.clj      |  15 +
 .../clj/backtype/storm/versioned_store_test.clj |  15 +
 .../test/clj/storm/trident/integration_test.clj |  15 +
 .../test/clj/storm/trident/state_test.clj       |  15 +
 .../test/clj/storm/trident/tuple_test.clj       |  15 +
 storm-core/test/clj/zilch/test/mq.clj           |  15 +
 storm-lib/project.clj                           |  15 +
 storm-netty/project.clj                         |  15 +
 .../backtype/storm/messaging/netty/Client.java  |  17 ++
 .../backtype/storm/messaging/netty/Context.java |  17 ++
 .../storm/messaging/netty/ControlMessage.java   |  17 ++
 .../storm/messaging/netty/MessageBatch.java     |  17 ++
 .../storm/messaging/netty/MessageDecoder.java   |  17 ++
 .../storm/messaging/netty/MessageEncoder.java   |  17 ++
 .../backtype/storm/messaging/netty/Server.java  |  17 ++
 .../messaging/netty/StormClientHandler.java     |  17 ++
 .../netty/StormClientPipelineFactory.java       |  17 ++
 .../messaging/netty/StormServerHandler.java     |  17 ++
 .../netty/StormServerPipelineFactory.java       |  17 ++
 .../storm/messaging/netty_integration_test.clj  |  15 +
 .../storm/messaging/netty_unit_test.clj         |  15 +
 562 files changed, 10047 insertions(+), 691 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-storm/blob/7e40f9f6/storm-core/project.clj
----------------------------------------------------------------------


Mime
View raw message