allow null parallelism for components

Nathan Marz · Nathan Marz · commit 2a731bc03f79 · 2012-01-28T01:48:42.000-08:00
diff --git a/src/jvm/backtype/storm/transactional/TransactionalTopologyBuilder.java b/src/jvm/backtype/storm/transactional/TransactionalTopologyBuilder.java
@@ -161,12 +161,12 @@ private Set<String> componentBoltSubscriptions(Component component) {
 
     private static class Component {
         public IRichBolt bolt;
-        public int parallelism;
+        public Integer parallelism;
         public List<InputDeclaration> declarations = new ArrayList<InputDeclaration>();
         public List<Map> componentConfs = new ArrayList<Map>();
         public boolean committer;
         
-        public Component(IRichBolt bolt, int parallelism, boolean committer) {
+        public Component(IRichBolt bolt, Integer parallelism, boolean committer) {
             this.bolt = bolt;
             this.parallelism = parallelism;
             this.committer = committer;
