backtype.storm.coordination
Class BatchSubtopologyBuilder
java.lang.Object
backtype.storm.coordination.BatchSubtopologyBuilder
public class BatchSubtopologyBuilder
- extends java.lang.Object
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
BatchSubtopologyBuilder
public BatchSubtopologyBuilder(java.lang.String masterBoltId,
IBasicBolt masterBolt,
java.lang.Number boltParallelism)
BatchSubtopologyBuilder
public BatchSubtopologyBuilder(java.lang.String masterBoltId,
IBasicBolt masterBolt)
getMasterDeclarer
public BoltDeclarer getMasterDeclarer()
setBolt
public BoltDeclarer setBolt(java.lang.String id,
IBatchBolt bolt)
setBolt
public BoltDeclarer setBolt(java.lang.String id,
IBatchBolt bolt,
java.lang.Number parallelism)
setBolt
public BoltDeclarer setBolt(java.lang.String id,
IBasicBolt bolt)
setBolt
public BoltDeclarer setBolt(java.lang.String id,
IBasicBolt bolt,
java.lang.Number parallelism)
extendTopology
public void extendTopology(TopologyBuilder builder)