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 parallelism_hint)
Define a new bolt in this topology.
|
Copyright © 2019 The Apache Software Foundation. All rights reserved.