Class TridentTopologyBuilder
java.lang.Object
org.apache.storm.trident.topology.TridentTopologyBuilder
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionbuildTopology(Map<String, Number> masterCoordResources) setBatchPerTupleSpout(String id, String streamName, IRichSpout spout, Integer parallelism, String batchGroup) setBolt(String id, ITridentBatchBolt bolt, Integer parallelism, Set<String> committerBatches, Map<String, String> batchGroups) setSpout(String id, String streamName, String txStateId, IBatchSpout spout, Integer parallelism, String batchGroup) setSpout(String id, String streamName, String txStateId, ITridentSpout spout, Integer parallelism, String batchGroup) static StringspoutCoordinator(String spoutId) static StringspoutIdFromCoordinatorId(String coordId) 
- 
Constructor Details- 
TridentTopologyBuilderpublic TridentTopologyBuilder()
 
- 
- 
Method Details- 
spoutCoordinator
- 
spoutIdFromCoordinatorId
- 
setBatchPerTupleSpoutpublic SpoutDeclarer setBatchPerTupleSpout(String id, String streamName, IRichSpout spout, Integer parallelism, String batchGroup) 
- 
setSpoutpublic SpoutDeclarer setSpout(String id, String streamName, String txStateId, IBatchSpout spout, Integer parallelism, String batchGroup) 
- 
setSpoutpublic SpoutDeclarer setSpout(String id, String streamName, String txStateId, ITridentSpout spout, Integer parallelism, String batchGroup) 
- 
setBoltpublic BoltDeclarer setBolt(String id, ITridentBatchBolt bolt, Integer parallelism, Set<String> committerBatches, Map<String, String> batchGroups) 
- 
buildTopology
 
-