Github user asfgit closed the pull request at:
https://github.com/apache/storm/pull/1760
---
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1760#discussion_r86603766
--- Diff:
external/storm-redis/src/main/java/org/apache/storm/redis/bolt/RedisFilterBolt.java
---
@@ -45,18 +48,41 @@
*/
public class
Github user mo-getter commented on a diff in the pull request:
https://github.com/apache/storm/pull/1760#discussion_r86495472
--- Diff:
external/storm-redis/src/main/java/org/apache/storm/redis/bolt/RedisFilterBolt.java
---
@@ -45,18 +48,41 @@
*/
public class
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1760#discussion_r86378199
--- Diff:
external/storm-redis/src/main/java/org/apache/storm/redis/bolt/RedisFilterBolt.java
---
@@ -45,18 +48,41 @@
*/
public class
GitHub user mo-getter opened a pull request:
https://github.com/apache/storm/pull/1760
Add topology stream-awareness to storm-redis
Allows users to control the streams to which the provided Bolts emit, via a
StreamMapper interface, rather than emitting only to the "default" stream.