Class TridentTopologyBuilder
java.lang.Object
org.apache.storm.trident.topology.TridentTopologyBuilder
-
Constructor Summary
Constructors -
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 StringspoutCoordinator(String spoutId) static StringspoutIdFromCoordinatorId(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
-