refs/heads/0.5.0 - storm

commit: 9d91adbdbde22e91779b91eb40805f598da5b004
[log]
author: Nathan Marz <nathan@twitter.com>
Sat Sep 17 00:48:10 2011 -0700
committer: Nathan Marz <nathan@twitter.com>
Sat Sep 17 00:48:10 2011 -0700
tree: 160565c5cabf8bf7a5bdca38196c41066f820458

release commit

.gitignore[Added - diff]
LICENSE.html[Added - diff]
README.markdown[Added - diff]
TODO[Added - diff]
bin/build_release.sh[Added - diff]
bin/install_zmq.sh[Added - diff]
bin/javadoc.sh[Added - diff]
bin/storm[Added - diff]
conf/defaults.yaml[Added - diff]
conf/log4j.properties[Added - diff]
conf/storm.yaml.example[Added - diff]
log4j/log4j.properties[Added - diff]
project.clj[Added - diff]
src/clj/backtype/storm/LocalCluster.clj[Added - diff]
src/clj/backtype/storm/bootstrap.clj[Added - diff]
src/clj/backtype/storm/clojure.clj[Added - diff]
src/clj/backtype/storm/cluster.clj[Added - diff]
src/clj/backtype/storm/command/config_value.clj[Added - diff]
src/clj/backtype/storm/command/kill_topology.clj[Added - diff]
src/clj/backtype/storm/command/shell_submission.clj[Added - diff]
src/clj/backtype/storm/config.clj[Added - diff]
src/clj/backtype/storm/daemon/common.clj[Added - diff]
src/clj/backtype/storm/daemon/drpc.clj[Added - diff]
src/clj/backtype/storm/daemon/nimbus.clj[Added - diff]
src/clj/backtype/storm/daemon/supervisor.clj[Added - diff]
src/clj/backtype/storm/daemon/task.clj[Added - diff]
src/clj/backtype/storm/daemon/worker.clj[Added - diff]
src/clj/backtype/storm/event.clj[Added - diff]
src/clj/backtype/storm/log.clj[Added - diff]
src/clj/backtype/storm/process_simulator.clj[Added - diff]
src/clj/backtype/storm/stats.clj[Added - diff]
src/clj/backtype/storm/testing.clj[Added - diff]
src/clj/backtype/storm/thrift.clj[Added - diff]
src/clj/backtype/storm/tuple.clj[Added - diff]
src/clj/backtype/storm/ui/core.clj[Added - diff]
src/clj/backtype/storm/ui/helpers.clj[Added - diff]
src/clj/backtype/storm/util.clj[Added - diff]
src/clj/backtype/storm/zookeeper.clj[Added - diff]
src/clj/zilch/mq.clj[Added - diff]
src/clj/zilch/virtual_port.clj[Added - diff]
src/dev/resources/storm.fy[Added - diff]
src/dev/resources/storm.py[Added - diff]
src/dev/resources/storm.rb[Added - diff]
src/dev/resources/tester.fy[Added - diff]
src/dev/resources/tester.py[Added - diff]
src/dev/resources/tester.rb[Added - diff]
src/genthrift.sh[Added - diff]
src/jvm/backtype/storm/Config.java[Added - diff]
src/jvm/backtype/storm/Constants.java[Added - diff]
src/jvm/backtype/storm/ILocalCluster.java[Added - diff]
src/jvm/backtype/storm/StormSubmitter.java[Added - diff]
src/jvm/backtype/storm/clojure/ClojureBolt.java[Added - diff]
src/jvm/backtype/storm/daemon/Shutdownable.java[Added - diff]
src/jvm/backtype/storm/drpc/DRPCScheme.java[Added - diff]
src/jvm/backtype/storm/drpc/ReturnResults.java[Added - diff]
src/jvm/backtype/storm/drpc/SpoutAdder.java[Added - diff]
src/jvm/backtype/storm/generated/AlreadyAliveException.java[Added - diff]
src/jvm/backtype/storm/generated/Bolt.java[Added - diff]
src/jvm/backtype/storm/generated/BoltStats.java[Added - diff]
src/jvm/backtype/storm/generated/ClusterSummary.java[Added - diff]
src/jvm/backtype/storm/generated/ComponentCommon.java[Added - diff]
src/jvm/backtype/storm/generated/ComponentObject.java[Added - diff]
src/jvm/backtype/storm/generated/DistributedRPC.java[Added - diff]
src/jvm/backtype/storm/generated/ErrorInfo.java[Added - diff]
src/jvm/backtype/storm/generated/GlobalStreamId.java[Added - diff]
src/jvm/backtype/storm/generated/Grouping.java[Added - diff]
src/jvm/backtype/storm/generated/InvalidTopologyException.java[Added - diff]
src/jvm/backtype/storm/generated/Nimbus.java[Added - diff]
src/jvm/backtype/storm/generated/NotAliveException.java[Added - diff]
src/jvm/backtype/storm/generated/NullStruct.java[Added - diff]
src/jvm/backtype/storm/generated/ShellComponent.java[Added - diff]
src/jvm/backtype/storm/generated/SpoutSpec.java[Added - diff]
src/jvm/backtype/storm/generated/SpoutStats.java[Added - diff]
src/jvm/backtype/storm/generated/StateSpoutSpec.java[Added - diff]
src/jvm/backtype/storm/generated/StormTopology.java[Added - diff]
src/jvm/backtype/storm/generated/StreamInfo.java[Added - diff]
src/jvm/backtype/storm/generated/SupervisorSummary.java[Added - diff]
src/jvm/backtype/storm/generated/TaskSpecificStats.java[Added - diff]
src/jvm/backtype/storm/generated/TaskStats.java[Added - diff]
src/jvm/backtype/storm/generated/TaskSummary.java[Added - diff]
src/jvm/backtype/storm/generated/TopologyInfo.java[Added - diff]
src/jvm/backtype/storm/generated/TopologySummary.java[Added - diff]
src/jvm/backtype/storm/planner/CompoundSpout.java[Added - diff]
src/jvm/backtype/storm/planner/CompoundTask.java[Added - diff]
src/jvm/backtype/storm/planner/TaskBundle.java[Added - diff]
src/jvm/backtype/storm/serialization/FieldSerialization.java[Added - diff]
src/jvm/backtype/storm/serialization/ISerialization.java[Added - diff]
src/jvm/backtype/storm/serialization/SerializationFactory.java[Added - diff]
src/jvm/backtype/storm/serialization/TupleDeserializer.java[Added - diff]
src/jvm/backtype/storm/serialization/TupleSerializer.java[Added - diff]
src/jvm/backtype/storm/serialization/ValuesDeserializer.java[Added - diff]
src/jvm/backtype/storm/serialization/ValuesSerializer.java[Added - diff]
src/jvm/backtype/storm/spout/ISpout.java[Added - diff]
src/jvm/backtype/storm/spout/ISpoutOutputCollector.java[Added - diff]
src/jvm/backtype/storm/spout/RawScheme.java[Added - diff]
src/jvm/backtype/storm/spout/Scheme.java[Added - diff]
src/jvm/backtype/storm/spout/ShellSpout.java[Added - diff]
src/jvm/backtype/storm/spout/SpoutOutputCollector.java[Added - diff]
src/jvm/backtype/storm/state/IStateSpout.java[Added - diff]
src/jvm/backtype/storm/state/IStateSpoutOutputCollector.java[Added - diff]
src/jvm/backtype/storm/state/ISubscribedState.java[Added - diff]
src/jvm/backtype/storm/state/ISynchronizeOutputCollector.java[Added - diff]
src/jvm/backtype/storm/state/StateSpoutOutputCollector.java[Added - diff]
src/jvm/backtype/storm/state/SynchronizeOutputCollector.java[Added - diff]
src/jvm/backtype/storm/task/CoordinatedBolt.java[Added - diff]
src/jvm/backtype/storm/task/IBolt.java[Added - diff]
src/jvm/backtype/storm/task/IInternalOutputCollector.java[Added - diff]
src/jvm/backtype/storm/task/IOutputCollector.java[Added - diff]
src/jvm/backtype/storm/task/KeyedFairBolt.java[Added - diff]
src/jvm/backtype/storm/task/OutputCollector.java[Added - diff]
src/jvm/backtype/storm/task/OutputCollectorImpl.java[Added - diff]
src/jvm/backtype/storm/task/ShellBolt.java[Added - diff]
src/jvm/backtype/storm/task/TopologyContext.java[Added - diff]
src/jvm/backtype/storm/testing/AckFailDelegate.java[Added - diff]
src/jvm/backtype/storm/testing/AckTracker.java[Added - diff]
src/jvm/backtype/storm/testing/BoltTracker.java[Added - diff]
src/jvm/backtype/storm/testing/FeederSpout.java[Added - diff]
src/jvm/backtype/storm/testing/FixedTuple.java[Added - diff]
src/jvm/backtype/storm/testing/FixedTupleSpout.java[Added - diff]
src/jvm/backtype/storm/testing/SpoutTracker.java[Added - diff]
src/jvm/backtype/storm/testing/TestAggregatesCounter.java[Added - diff]
src/jvm/backtype/storm/testing/TestGlobalCount.java[Added - diff]
src/jvm/backtype/storm/testing/TestPlannerBolt.java[Added - diff]
src/jvm/backtype/storm/testing/TestPlannerSpout.java[Added - diff]
src/jvm/backtype/storm/testing/TestWordCounter.java[Added - diff]
src/jvm/backtype/storm/testing/TestWordSpout.java[Added - diff]
src/jvm/backtype/storm/testing/TrackerAggregator.java[Added - diff]
src/jvm/backtype/storm/testing/TupleCaptureBolt.java[Added - diff]
src/jvm/backtype/storm/topology/BasicBoltExecutor.java[Added - diff]
src/jvm/backtype/storm/topology/BasicOutputCollector.java[Added - diff]
src/jvm/backtype/storm/topology/IBasicBolt.java[Added - diff]
src/jvm/backtype/storm/topology/IBasicOutputCollector.java[Added - diff]
src/jvm/backtype/storm/topology/IComponent.java[Added - diff]
src/jvm/backtype/storm/topology/IRichBolt.java[Added - diff]
src/jvm/backtype/storm/topology/IRichSpout.java[Added - diff]
src/jvm/backtype/storm/topology/IRichStateSpout.java[Added - diff]
src/jvm/backtype/storm/topology/InputDeclarer.java[Added - diff]
src/jvm/backtype/storm/topology/OutputFieldsDeclarer.java[Added - diff]
src/jvm/backtype/storm/topology/OutputFieldsGetter.java[Added - diff]
src/jvm/backtype/storm/topology/TopologyBuilder.java[Added - diff]
src/jvm/backtype/storm/tuple/Fields.java[Added - diff]
src/jvm/backtype/storm/tuple/MessageId.java[Added - diff]
src/jvm/backtype/storm/tuple/Tuple.java[Added - diff]
src/jvm/backtype/storm/tuple/Values.java[Added - diff]
src/jvm/backtype/storm/utils/BufferFileInputStream.java[Added - diff]
src/jvm/backtype/storm/utils/CRC32OutputStream.java[Added - diff]
src/jvm/backtype/storm/utils/DRPCClient.java[Added - diff]
src/jvm/backtype/storm/utils/KeyedRoundRobinQueue.java[Added - diff]
src/jvm/backtype/storm/utils/LocalState.java[Added - diff]
src/jvm/backtype/storm/utils/NimbusClient.java[Added - diff]
src/jvm/backtype/storm/utils/Time.java[Added - diff]
src/jvm/backtype/storm/utils/TimeCacheMap.java[Added - diff]
src/jvm/backtype/storm/utils/Utils.java[Added - diff]
src/jvm/backtype/storm/utils/VersionedStore.java[Added - diff]
src/jvm/backtype/storm/utils/WritableUtils.java[Added - diff]
src/multilang/fy/storm.fancypack[Added - diff]
src/multilang/fy/storm.fy[Added - diff]
src/multilang/py/storm.py[Added - diff]
src/multilang/rb/storm.rb[Added - diff]
src/py/__init__.py[Added - diff]
src/py/storm/DistributedRPC-remote[Added - diff]
src/py/storm/DistributedRPC.py[Added - diff]
src/py/storm/Nimbus-remote[Added - diff]
src/py/storm/Nimbus.py[Added - diff]
src/py/storm/__init__.py[Added - diff]
src/py/storm/constants.py[Added - diff]
src/py/storm/ttypes.py[Added - diff]
src/storm.thrift[Added - diff]
src/ui/public/css/bootstrap-1.1.0.css[Added - diff]
src/ui/public/js/jquery-1.6.2.min.js[Added - diff]
src/ui/public/js/jquery.tablesorter.min.js[Added - diff]
test/clj/backtype/storm/cluster_test.clj[Added - diff]
test/clj/backtype/storm/integration_test.clj[Added - diff]
test/clj/backtype/storm/local_state_test.clj[Added - diff]
test/clj/backtype/storm/nimbus_test.clj[Added - diff]
test/clj/backtype/storm/supervisor_test.clj[Added - diff]
test/clj/backtype/storm/versioned_store_test.clj[Added - diff]
test/clj/zilch/test/mq.clj[Added - diff]
test/multilang/fy/bolt.fy[Added - diff]
test/multilang/fy/mocks.fy[Added - diff]
test/multilang/fy/protocol.fy[Added - diff]

181 files changed

tree: 160565c5cabf8bf7a5bdca38196c41066f820458