Package | Description |
---|---|
org.apache.storm |
Modifier and Type | Method and Description |
---|---|
static Thrift.SpoutDetails |
Thrift.prepareSpoutDetails(IRichSpout spout) |
static Thrift.SpoutDetails |
Thrift.prepareSpoutDetails(IRichSpout spout,
Integer parallelismHint) |
static Thrift.SpoutDetails |
Thrift.prepareSpoutDetails(IRichSpout spout,
Integer parallelismHint,
Map<String,Object> conf) |
Modifier and Type | Method and Description |
---|---|
static StormTopology |
Thrift.buildTopology(HashMap<String,Thrift.SpoutDetails> spoutMap,
HashMap<String,Thrift.BoltDetails> boltMap,
HashMap<String,StateSpoutSpec> stateMap) |
static StormTopology |
Thrift.buildTopology(Map<String,Thrift.SpoutDetails> spoutMap,
Map<String,Thrift.BoltDetails> boltMap) |
Copyright © 2020 The Apache Software Foundation. All rights reserved.