Uses of Interface
org.apache.storm.topology.SpoutDeclarer
Packages that use SpoutDeclarer
-
Uses of SpoutDeclarer in org.apache.storm.topology
Classes in org.apache.storm.topology that implement SpoutDeclarerMethods in org.apache.storm.topology that return SpoutDeclarerModifier 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
Methods in org.apache.storm.trident.topology that return SpoutDeclarerModifier 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)