Uses of Interface
org.apache.storm.lambda.SerializableConsumer
-
Packages that use SerializableConsumer Package Description org.apache.storm.lambda org.apache.storm.topology -
-
Uses of SerializableConsumer in org.apache.storm.lambda
Constructors in org.apache.storm.lambda with parameters of type SerializableConsumer Constructor Description LambdaConsumerBolt(SerializableConsumer<Tuple> consumer)
-
Uses of SerializableConsumer in org.apache.storm.topology
Methods in org.apache.storm.topology with parameters of type SerializableConsumer Modifier and Type Method Description BoltDeclarer
TopologyBuilder. setBolt(String id, SerializableConsumer<Tuple> consumer)
Define a new bolt in this topology.BoltDeclarer
TopologyBuilder. setBolt(String id, SerializableConsumer<Tuple> consumer, Number parallelismHint)
Define a new bolt in this topology.
-