Class TridentTopologyBuilder
java.lang.Object
org.apache.storm.trident.topology.TridentTopologyBuilder
-
Constructor Summary
-
Method Summary
Modifier 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 String
spoutCoordinator
(String spoutId) static String
spoutIdFromCoordinatorId
(String coordId)
-
Constructor Details
-
TridentTopologyBuilder
public TridentTopologyBuilder()
-
-
Method Details
-
spoutCoordinator
-
spoutIdFromCoordinatorId
-
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
-