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