backtype.storm.drpc
Class LinearDRPCTopologyBuilder
java.lang.Object
backtype.storm.drpc.LinearDRPCTopologyBuilder
public class LinearDRPCTopologyBuilder
- extends java.lang.Object
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
LinearDRPCTopologyBuilder
public LinearDRPCTopologyBuilder(java.lang.String function)
addBolt
public LinearDRPCInputDeclarer addBolt(IBatchBolt bolt,
int parallelism)
addBolt
public LinearDRPCInputDeclarer addBolt(IBatchBolt bolt)
addBolt
@Deprecated
public LinearDRPCInputDeclarer addBolt(IRichBolt bolt,
int parallelism)
- Deprecated.
addBolt
@Deprecated
public LinearDRPCInputDeclarer addBolt(IRichBolt bolt)
- Deprecated.
addBolt
public LinearDRPCInputDeclarer addBolt(IBasicBolt bolt,
int parallelism)
addBolt
public LinearDRPCInputDeclarer addBolt(IBasicBolt bolt)
createLocalTopology
public StormTopology createLocalTopology(ILocalDRPC drpc)
createRemoteTopology
public StormTopology createRemoteTopology()