Uses of Interface
org.apache.storm.topology.SpoutDeclarer
-
Packages that use SpoutDeclarer Package Description org.apache.storm.topology org.apache.storm.trident.topology -
-
Uses of SpoutDeclarer in org.apache.storm.topology
Classes in org.apache.storm.topology that implement SpoutDeclarer Modifier and Type Class Description protected class
TopologyBuilder.SpoutGetter
Methods in org.apache.storm.topology that return SpoutDeclarer Modifier and Type Method Description SpoutDeclarer
TopologyBuilder. setSpout(String id, SerializableSupplier<?> supplier)
Define a new spout in this topology.SpoutDeclarer
TopologyBuilder. setSpout(String id, SerializableSupplier<?> supplier, Number parallelismHint)
Define a new spout in this topology with the specified parallelism.SpoutDeclarer
TopologyBuilder. setSpout(String id, IRichSpout spout)
Define a new spout in this topology.SpoutDeclarer
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 SpoutDeclarer Modifier and Type Method Description SpoutDeclarer
TridentTopologyBuilder. setBatchPerTupleSpout(String id, String streamName, IRichSpout spout, Integer parallelism, String batchGroup)
SpoutDeclarer
TridentTopologyBuilder. setSpout(String id, String streamName, String txStateId, IBatchSpout spout, Integer parallelism, String batchGroup)
SpoutDeclarer
TridentTopologyBuilder. setSpout(String id, String streamName, String txStateId, ITridentSpout spout, Integer parallelism, String batchGroup)
-