Uses of Interface
org.apache.storm.topology.SpoutDeclarer
-
Uses of SpoutDeclarer in org.apache.storm.topology
Modifier and TypeMethodDescriptionTopologyBuilder.setSpout
(String id, SerializableSupplier<?> supplier) Define a new spout in this topology.TopologyBuilder.setSpout
(String id, SerializableSupplier<?> supplier, Number parallelismHint) Define a new spout in this topology with the specified parallelism.TopologyBuilder.setSpout
(String id, IRichSpout spout) Define a new spout in this topology.TopologyBuilder.setSpout
(String id, IRichSpout spout, Number parallelismHint) Define a new spout in this topology with the specified parallelism. -
Uses of SpoutDeclarer in org.apache.storm.trident.topology
Modifier and TypeMethodDescriptionTridentTopologyBuilder.setBatchPerTupleSpout
(String id, String streamName, IRichSpout spout, Integer parallelism, String batchGroup) TridentTopologyBuilder.setSpout
(String id, String streamName, String txStateId, IBatchSpout spout, Integer parallelism, String batchGroup) TridentTopologyBuilder.setSpout
(String id, String streamName, String txStateId, ITridentSpout spout, Integer parallelism, String batchGroup)