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 © 2020 The Apache Software Foundation. All rights reserved.