Uses of Interface
org.apache.storm.lambda.SerializableConsumer
-
Uses of SerializableConsumer in org.apache.storm.lambda
-
Uses of SerializableConsumer in org.apache.storm.topology
Modifier and TypeMethodDescriptionTopologyBuilder.setBolt
(String id, SerializableConsumer<Tuple> consumer) Define a new bolt in this topology.TopologyBuilder.setBolt
(String id, SerializableConsumer<Tuple> consumer, Number parallelismHint) Define a new bolt in this topology.