public class TopologySpoutLag extends Object
| Constructor and Description |
|---|
TopologySpoutLag() |
| Modifier and Type | Method and Description |
|---|---|
static Map<String,Map<String,Object>> |
lag(StormTopology stormTopology,
Map<String,Object> topologyConf) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.