Package org.apache.storm.coordination
Class BatchSubtopologyBuilder
- java.lang.Object
-
- org.apache.storm.coordination.BatchSubtopologyBuilder
-
public class BatchSubtopologyBuilder extends Object
-
-
Constructor Summary
Constructors Constructor Description BatchSubtopologyBuilder(String masterBoltId, IBasicBolt masterBolt)BatchSubtopologyBuilder(String masterBoltId, IBasicBolt masterBolt, Number boltParallelism)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidextendTopology(TopologyBuilder builder)BoltDeclarergetMasterDeclarer()BoltDeclarersetBolt(String id, IBatchBolt bolt)BoltDeclarersetBolt(String id, IBatchBolt bolt, Number parallelism)BoltDeclarersetBolt(String id, IBasicBolt bolt)BoltDeclarersetBolt(String id, IBasicBolt bolt, Number parallelism)
-
-
-
Constructor Detail
-
BatchSubtopologyBuilder
public BatchSubtopologyBuilder(String masterBoltId, IBasicBolt masterBolt, Number boltParallelism)
-
BatchSubtopologyBuilder
public BatchSubtopologyBuilder(String masterBoltId, IBasicBolt masterBolt)
-
-
Method Detail
-
getMasterDeclarer
public BoltDeclarer getMasterDeclarer()
-
setBolt
public BoltDeclarer setBolt(String id, IBatchBolt bolt)
-
setBolt
public BoltDeclarer setBolt(String id, IBatchBolt bolt, Number parallelism)
-
setBolt
public BoltDeclarer setBolt(String id, IBasicBolt bolt)
-
setBolt
public BoltDeclarer setBolt(String id, IBasicBolt bolt, Number parallelism)
-
extendTopology
public void extendTopology(TopologyBuilder builder)
-
-