| Package | Description |
|---|---|
| org.apache.storm.lambda | |
| org.apache.storm.topology |
| Constructor and Description |
|---|
LambdaSpout(SerializableSupplier<?> supplier) |
| Modifier and Type | Method and Description |
|---|---|
SpoutDeclarer |
TopologyBuilder.setSpout(String id,
SerializableSupplier<?> supplier)
Define a new spout in this topology.
|
SpoutDeclarer |
TopologyBuilder.setSpout(String id,
SerializableSupplier<?> supplier,
Number parallelismHint)
Define a new spout in this topology with the specified parallelism.
|
Copyright © 2021 The Apache Software Foundation. All rights reserved.