Repository: storm Updated Branches: refs/heads/1.0.x-branch a39d1cadb -> b184ed7a3
STORM-1878: Flux can now handle IStatefulBolts Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/7713a552 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/7713a552 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/7713a552 Branch: refs/heads/1.0.x-branch Commit: 7713a5525e7b66a53ed4996653c7f1a54f71d85e Parents: a39d1ca Author: Daniel Klessing <[email protected]> Authored: Thu Jun 2 13:19:11 2016 +0200 Committer: Arun Mahadevan <[email protected]> Committed: Tue Jun 7 12:07:38 2016 +0530 ---------------------------------------------------------------------- .../src/main/java/org/apache/storm/flux/FluxBuilder.java | 8 ++++++++ 1 file changed, 8 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/7713a552/external/flux/flux-core/src/main/java/org/apache/storm/flux/FluxBuilder.java ---------------------------------------------------------------------- diff --git a/external/flux/flux-core/src/main/java/org/apache/storm/flux/FluxBuilder.java b/external/flux/flux-core/src/main/java/org/apache/storm/flux/FluxBuilder.java index 00e1201..77b89f9 100644 --- a/external/flux/flux-core/src/main/java/org/apache/storm/flux/FluxBuilder.java +++ b/external/flux/flux-core/src/main/java/org/apache/storm/flux/FluxBuilder.java @@ -175,6 +175,14 @@ public class FluxBuilder { topologyDef.parallelismForBolt(stream.getTo())); declarers.put(stream.getTo(), declarer); } + } else if (boltObj instanceof IStatefulBolt) { + if(declarer == null) { + declarer = builder.setBolt( + stream.getTo(), + (IStatefulBolt) boltObj, + topologyDef.parallelismForBolt(stream.getTo())); + declarers.put(stream.getTo(), declarer); + } } else { throw new IllegalArgumentException("Class does not appear to be a bolt: " + boltObj.getClass().getName());
