| Package | Description |
|---|---|
| org.apache.storm.lambda | |
| org.apache.storm.topology |
| Constructor and Description |
|---|
LambdaBiConsumerBolt(SerializableBiConsumer<Tuple,BasicOutputCollector> biConsumer,
String[] fields) |
| Modifier and Type | Method and Description |
|---|---|
BoltDeclarer |
TopologyBuilder.setBolt(String id,
SerializableBiConsumer<Tuple,BasicOutputCollector> biConsumer,
Number parallelismHint,
String... fields)
Define a new bolt in this topology.
|
BoltDeclarer |
TopologyBuilder.setBolt(String id,
SerializableBiConsumer<Tuple,BasicOutputCollector> biConsumer,
String... fields)
Define a new bolt in this topology.
|
Copyright © 2021 The Apache Software Foundation. All rights reserved.