Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Browse files

Merge storm-signals v0.1.0 release

  • Loading branch information...
commit adeadaafa41136a4ab7d50186930f1b188307b57 1 parent 26cefb8
P. Taylor Goetz ptgoetz authored
13 storm-signals/README.md
View
@@ -4,13 +4,24 @@ Storm-Signals aims to provide a way to send messages ("signals") to components (
Storm topologies can be considered static in that modifications to a topology's behavior require redeployment. Storm-Signals provides a simple way to modify a topology's behavior at runtime, without redeployment.
+### Project Location
+Primary development of storm-signals will take place at:
+https://github.com/ptgoetz/storm-signals
+
+Point/stable (non-SNAPSHOT) release souce code will be pushed to:
+https://github.com/nathanmarz/storm-contrib
+
+Maven artifacts for releases will be available on maven central.
+
+
+
### Use Cases
Typical storm spouts run forever (until undeployed), emitting tuples based on an underlying, presumably event-driven, data source/stream.
Some storm users have expressed an interest in having more control over that pattern, for instance in situations where the data stream is not open-ended, or where the situation requires that data streams be controllable (i.e. the ability to start/stop/pause/resume processing).
-Storm-Signals provides a very simple mechanism for communicating with spouts deployed within a storm topology. The comunication mechanism resides outside of storm's basic stream processing paradigm (i.e. calls to `nextTuple()` and the tuple ack/fail mechanism).
+Storm-Signals provides a very simple mechanism for communicating with spouts deployed within a storm topology. The communication mechanism resides outside of storm's basic stream processing paradigm (i.e. calls to `nextTuple()` and the tuple ack/fail mechanism).
Signals (messages)
8 storm-signals/pom.xml
View
@@ -9,7 +9,7 @@
<modelVersion>4.0.0</modelVersion>
<groupId>com.github.ptgoetz</groupId>
<artifactId>storm-signals</artifactId>
- <version>0.1.0-SNAPSHOT</version>
+ <version>0.1.0</version>
<name>Storm Signals</name>
<description>Storm Signals</description>
@@ -26,12 +26,6 @@
<developerConnection>scm:git:git@github.com:ptgoetz/storm-signals.git</developerConnection>
<url>:git@github.com:ptgoetz/storm-signals.git</url>
</scm>
- <repositories>
- <repository>
- <id>clojars.org</id>
- <url>http://clojars.org/repo</url>
- </repository>
- </repositories>
<developers>
<developer>
<id>ptgoetz</id>
4 storm-signals/src/main/java/backtype/storm/contrib/signals/test/TestSignalSpout.java
View
@@ -2,14 +2,10 @@
package backtype.storm.contrib.signals.test;
-import java.util.Map;
-
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import backtype.storm.contrib.signals.spout.BaseSignalSpout;
-import backtype.storm.spout.SpoutOutputCollector;
-import backtype.storm.task.TopologyContext;
import backtype.storm.topology.OutputFieldsDeclarer;
public class TestSignalSpout extends BaseSignalSpout {

1 comment on commit adeadaa

Pablo Barrera

Relase 0.2 is available, is anybody working on merging it into this project?

Please sign in to comment.
Something went wrong with that request. Please try again.