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