Class TridentTopologyBuilder
- java.lang.Object
-
- org.apache.storm.trident.topology.TridentTopologyBuilder
-
public class TridentTopologyBuilder extends Object
-
-
Constructor Summary
Constructors Constructor Description TridentTopologyBuilder()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description StormTopologybuildTopology(Map<String,Number> masterCoordResources)SpoutDeclarersetBatchPerTupleSpout(String id, String streamName, IRichSpout spout, Integer parallelism, String batchGroup)BoltDeclarersetBolt(String id, ITridentBatchBolt bolt, Integer parallelism, Set<String> committerBatches, Map<String,String> batchGroups)SpoutDeclarersetSpout(String id, String streamName, String txStateId, IBatchSpout spout, Integer parallelism, String batchGroup)SpoutDeclarersetSpout(String id, String streamName, String txStateId, ITridentSpout spout, Integer parallelism, String batchGroup)static StringspoutCoordinator(String spoutId)static StringspoutIdFromCoordinatorId(String coordId)
-
-
-
Method Detail
-
setBatchPerTupleSpout
public SpoutDeclarer setBatchPerTupleSpout(String id, String streamName, IRichSpout spout, Integer parallelism, String batchGroup)
-
setSpout
public SpoutDeclarer setSpout(String id, String streamName, String txStateId, IBatchSpout spout, Integer parallelism, String batchGroup)
-
setSpout
public SpoutDeclarer setSpout(String id, String streamName, String txStateId, ITridentSpout spout, Integer parallelism, String batchGroup)
-
setBolt
public BoltDeclarer setBolt(String id, ITridentBatchBolt bolt, Integer parallelism, Set<String> committerBatches, Map<String,String> batchGroups)
-
buildTopology
public StormTopology buildTopology(Map<String,Number> masterCoordResources)
-
-