| Package | Description |
|---|---|
| org.apache.storm.lambda | |
| org.apache.storm.topology |
| Constructor and Description |
|---|
LambdaConsumerBolt(SerializableConsumer<Tuple> consumer) |
| Modifier and Type | Method and 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.
|
Copyright © 2021 The Apache Software Foundation. All rights reserved.