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 2013/12/13 18:15:02 UTC
[18/18] git commit: Merge pull request #767 from
ptgoetz/apache-headers
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 <pt...@gmail.com>
Authored: Thu Dec 12 17:21:37 2013 -0800
Committer: P. Taylor Goetz <pt...@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
----------------------------------------------------------------------