backtype.storm.drpc
Class LinearDRPCTopologyBuilder

java.lang.Object
  backtype.storm.drpc.LinearDRPCTopologyBuilder

public class LinearDRPCTopologyBuilder
extends java.lang.Object

Constructor Summary

LinearDRPCTopologyBuilder(java.lang.String function)

Method Summary

LinearDRPCInputDeclarer	addBolt(IBasicBolt bolt)
LinearDRPCInputDeclarer	addBolt(IBasicBolt bolt, int parallelism)
LinearDRPCInputDeclarer	addBolt(IBatchBolt bolt)
LinearDRPCInputDeclarer	addBolt(IBatchBolt bolt, int parallelism)
LinearDRPCInputDeclarer	addBolt(IRichBolt bolt) Deprecated.
LinearDRPCInputDeclarer	addBolt(IRichBolt bolt, int parallelism) Deprecated.
StormTopology	createLocalTopology(ILocalDRPC drpc)
StormTopology	createRemoteTopology()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LinearDRPCTopologyBuilder

public LinearDRPCTopologyBuilder(java.lang.String function)

Method Detail

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()